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

Question

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

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

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

我现在的来源：

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

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

score 0 · Accepted Answer

事实证明，不可能将元素添加到从队列等集合创建的 Source 中。集合中的可用元素将在流的物化期间传递，并且在处理这些元素时完成流。

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

阿卡文档：

1 回答 1