Source.fromIterator(..) 提供了迭代器线程安全

Question

应该Iterator传递给线程安全Source.fromIterator吗？官方文档链接会很好。

Answer 1

不。您的图表会按顺序拉取它们。即使在下游，在没有进行一些并行化的情况下，图形实际上对应于单个参与者。由于上述源代码的机制，您仍然可以使用传入的任何迭代器。