2016-05-08 2 views
2

У меня есть два предмета: $ и b $.RX Тема добавляет новый emit, используя последнее значение

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)}) 

или более succintly:

b$.withLatestFrom(a$, function (b,a){return a+b}) 
    .subscribe(a) 
Смежные вопросы