ребят, а подскажите плз, какой оператор или еще что может мне помочь
Мне нужно реализовать следующее:
1. Есть поток с данными
2. Есть еще один поток (а точнее Subject), в который я закидываю новые данные
3. Мне нужно обновлять значение в первом потоке, забирая значение из второго
Делаю я это таким образом:
const records = [{...}];
const newRecord = this.updateRecords.asObservable().pipe(startWith(null));
this.records = combineLatest([
of(records),
newRecord
]).pipe(
map(([allRecords, updatedRecord]) => {
const newRecords = ...
return newRecords;
})
)
проблема здесь в том, что когда происходит эмит значения, то берется дефолтное из of
(records)
подозреваю, что это должно выглядеть как-то так, чтобы оно работало
of(records).pipe(
whenEmits((updatedRecord) => {...})
)
подскажите, есть какой-то оператор, который будет слушать эмиты другого сабджекта?