rxjs中是否有逻辑或类型的运算符？

  • Z时代
  • 2024-01-10
  • 分类：问答

我有一个角度服务，我想暴露一个observable，它充当逻辑“或”的类。假设我有多个源序列可以给出on和off的值。我需要输出true任何时候任何东西都是on，并且当所有值为off时返回false。rxjs中是否有逻辑或类型的运算符？

例子：

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$)，所以这有点不错，但是我的输入不同步，所以并不总是完美的。我的意思是，第一美元可能放出一个以上的价值，而第二美元可能永远不会开火，反之亦然。我还可以做些什么？

我想过一些mergeMap或类似的，然后保持外部上下文的状态，这种方式我运行任何事件的更新。但是当我遇到问题时，“关闭”事件可能意味着“关闭”，但是只有其他序列也是“关闭”的时候，所以它很快就会变得棘手。

回答：

实际上，你给出的答案基本上都是自己：

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

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

我不明白你的意思，说实话。你在你的问题中明确表达了你想要的：

我需要在任何时候输出任何东西。

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

如果你想以某种方式等待所有输入改变，因为他们可能会在同一时间发生改变，您可以添加一个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"

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

回答：

看，如果这是你寻找什么

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)

以上是 rxjs中是否有逻辑或类型的运算符？ 的全部内容， 来源链接： utcz.com/qa/265306.html

回到顶部