У меня есть поток, который либо завершит, либо сгенерирует исключение (т. Е. Не бесконечный поток).
Он излучает 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
), не прибегая к локальным переменным для хранения промежуточного потока?