ребят, а подскажите плз, какой оператор или еще что может мне помочь

Мне нужно реализовать следующее:
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) => {...})
)

подскажите, есть какой-то оператор, который будет слушать эмиты другого сабджекта?

ребят, а подскажите плз, какой оператор или еще что может мне помочь

Мне нужно реализовать следующее:
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) => {...})
)

подскажите, есть какой-то оператор, который будет слушать эмиты другого сабджекта?

ребят, а подскажите плз, какой оператор или еще что может мне помочь

Мне нужно реализовать следующее:
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) => {...})
)

подскажите, есть какой-то оператор, который будет слушать эмиты другого сабджекта?

https://webdraftt.com/tutorial/rxjs/reduce может оно, но если нет потыкай там среди операторов

вот походу оно

RxJS reduce() передаст следующему обработчику только конечное вычисленное значение и только тогда, когда завершится выполнение исходного Observable.