【发布时间】:2016-08-15 01:48:26
【问题描述】:
我正在使用Typescript 1.9 编码并使用RxJS 5。我正在尝试构建一个仅发出一个值的可观察对象:true,如果任何内部Observable<number> 的排放属于固定的数字数组。 false 否则。这是我的代码:
let lookFor = [2,7]; // Values to look for are known
Observable.from([1,2,3,4,5]) //inner observable emits these dynamic values
.first( //find first value to meet the requirement below
(d:number) => lookFor.find(id=>id===d)!==undefined,
()=>true //projection function. What to emit when a match is found
)
.subscribe(
res => console.log('Result: ',res),
err => console.error(err),
() => console.log('Complete')
);
上面的代码效果很好。它将输出:
结果:true(因为内部 observable 发出 2,可在
lookFor中找到完成
如果我以Observable.from([8,9]) 开头,我想获得Result: false,因为与lookFor 没有重叠,而是触发了错误处理程序:
对象{名称:“空错误”,堆栈:“”}
什么是正确的方法让我的 observable 在找到匹配项后立即发出 true,但如果在流的末尾仍然没有匹配项,则发出 false?
【问题讨论】:
标签: typescript observable rxjs5