RxJS - Карта над последним элементом потока - PullRequest
0 голосов
/ 10 мая 2018

У меня есть поток, который либо завершит, либо сгенерирует исключение (т. Е. Не бесконечный поток).

Он излучает 2 значения (скажем, A и B), прежде чем завершится. Можно ли отобразить последнее значение, выпущенное на что-то еще?

stream$
    .debounceTime(100)
    .mergeMap(element =>
      api(stream$, ...) // This emits A B
        .last()
        .map(lastElement => f(lastElement.result)) // produces C based on B

Теперь у меня есть поток, содержащий только C, возможно ли сохранить A (чтобы $stream испускал A C), не прибегая к локальным переменным для хранения промежуточного потока?

...