如何阻止take
方法结束嵌套流,与平展一起使用?
嵌套流还有其他解决方案吗?我尝试合并没有结束符号fromDiagram
但显然这不起作用。
我被告知xs.never((是专门针对此用例的方法,虽然我仍然不知道为什么fromDiagram会失败,但我想这是一个足够的答案。
xs.merge(stream.take(1), xs.never()).map(nestedStream)