如何阻止流结束



如何阻止take方法结束嵌套流,与平展一起使用?

嵌套流还有其他解决方案吗?我尝试合并没有结束符号fromDiagram但显然这不起作用。

我被告知xs.never((是专门针对此用例的方法,虽然我仍然不知道为什么fromDiagram会失败,但我想这是一个足够的答案。

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

最新更新