是否可以在 javadsl 中为物化的 Akka 源引入更多值？

Question

我正在尝试使用 Akka 的 javadsl 设置一个流，它处理文件夹中新文件的处理。我的问题是：

我是否应该在每次引入新文件时重新运行 RunnableFlow，

或者是否有可能在流等待新文件被引入所述流的源时无限期地保持 RunnableFlow 运行ning？

我现在的来源：

Queue<Path> esbList = new Queue<>();
final Source<Path, BoxedUnit> pathSource = Source.from(esbList);

队列是一个简单的可迭代队列

Answer 1

事实证明，无法将元素添加到从队列等集合创建的源中。集合中的可用元素将在流的具体化过程中传递，并在处理这些元素时完成流。

正如 cmbaxter 提到的创建一个 Source，通过 ActorPublisher 创建 Source 可以在物化后添加元素。

Akka 文档：

http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0-RC3/java/stream-integrations.html#ActorPublisher

相关问题：