Как остановить поток от окончания

Question

Как остановить take метод завершения вложенных потоков, который будет использоваться с flatten?

Есть ли другое решение для вложенных потоков? Я пытался слить fromDiagram без символа конца, но, видимо, это не работает.

Answer 1

Мне сказали, что xs.never() - это метод, специально предназначенный для этого варианта использования, и хотя я до сих пор не знаю, почему из-за сбоя fromDiagram, я полагаю, этого достаточно.

xs.merge(stream.take(1), xs.never()).map(nestedStream)