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

Question

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

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

Answer 1

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

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