RX Subject добавить новый emit, используя последнее значение

У меня есть два предмета: a$ и b$.

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

Когда b $ испускает что-то, нужно принять это значение и добавить с последним выбросом из $. Затем необходимо отправить этот результат в $.

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

result

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

Я не могу найти решение этой задачи

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)
Другие вопросы по тегам