-1

如何阻止该take方法结束嵌套流，以便与 flatten 一起使用？

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

4

1 回答 1

0

我被告知 xs.never() 是专门针对这个用例的方法，虽然我仍然不知道为什么 fromDiagram 会失败，但我想这已经足够了。

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

于 2018-10-05T13:07:02.110 回答