javascript - RX Subject 使用最后一个值添加新的发射

Question

我有两个科目：a$ 和 b$。

var a$ = new Rx.Subject();
var b$ = new Rx.Subject();

当 b$ 发出一些东西时，需要取这个值并加上最后一个从 a$ 发出的东西。然后它需要把这个结果发送给 a$。

a$ ---4----6------------->
b$ -------------3-------->

result

a$ ---4----6----9-------->
b$ -------------3-------->

我找不到此任务的解决方案

Answer 1

您可能可以使用withLatestFrom运算符。例如 ：

b$.withLatestFrom(a$, function (b,a){return a+b})
  .subscribe(function(x){a.onNext(x)})

或更简洁地说：

b$.withLatestFrom(a$, function (b,a){return a+b})
  .subscribe(a)