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

Question

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

Answer 1

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