How to stop stream from ending

Question

How to stop the take method from ending nested streams, to be used with flatten?

Is there some other solution to nested streams? I tried merging fromDiagram without end symbol, but apparently that doesn't work.

Answer 1

I got told that xs.never() is method specifically for this use case, and while I still don't know why fromDiagram would fail, I suppose that is an answer enough.

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