1

我有一个角度服务，我想在其中公开一个充当逻辑“或”的可观察对象。假设我有多个可以给出on和off值的源序列。我需要在true任何时候输出任何东西on，然后回到false所有值都是off。

例子：

const replaceInput = input => input === 'on' ? 'off' : 'on';
const getSource = (name) => Observable.interval(1000)
    .scan(
        input => Math.random() > 0.5 ? replaceInput(input) : input,
        'off' // initial value
    )
    .do(val => console.log(`${name}: ${val});

const first$ = getSource('first');
const second$ = getSource('second');
const result$ = ???;

现在，我试过了result$ = Observable.merge(first$, second$)，但总是给出on。我也尝试过result$ = combineLatest(first$, second$)，所以这有点好，但是我的输入不同步，所以它并不总是完美的。我的意思是， first$ 可能会发出多个值，而 second 可能永远不会触发，反之亦然。我还可以做些什么？

我想到了一些 mergeMap 或类似的东西，然后将状态保持在外部上下文中，这样我就可以在任何事件上运行更新。但是后来我遇到了一个问题，“关闭”事件可能意味着“关闭”，但前提是其他序列也“关闭”，所以它很快就会变得棘手。

4

2 回答 2

2

您实际上基本上自己给出了答案：

const result$ = Observable.combineLatest(first$, second$)
  .map(values => values.some(value => value === 'on'));

所以这有点好，但我的输入不同步，所以它并不总是完美的。

老实说，我不明白你的意思。你在你的问题中明确表示你想要这个：

任何时候我都需要输出 true 。

因此，如果输入之间的时间延迟发生变化，您将获得中间结果状态。这与你的问题完全一致。

如果您想以某种方式等待所有输入更改，因为它们可能会同时更改，您可以添加一个debounceTime：

const result$ = Observable.combineLatest(first$, second$)
  .debounceTime(100)
  .map(values => values.some(value => value === 'on'));

或者，如果您想抑制false排放，只需过滤它们：

const result$ = Observable.combineLatest(first$, second$)
  .map(values => values.some(value => value === 'on'))
  .filter(Boolean); // sneaky trick; you can also use "value => value"

你当然可以将两者结合起来。

于 2017-12-27T14:48:51.180 回答
2

看看这是不是你要找的

let randomInput=()=>Rx.Observable.interval(1000)
.map(()=>Math.random()>0.5?'on':'off')
.startWith('off')
.map(value=>value==='on'?true:false)

Rx.Observable.combineLatest(randomInput(),randomInput())
.map(([first,second])=>first||second).subscribe(console.log)
于 2017-12-27T15:20:58.907 回答