akka - javadslで実体化されたAkka Sourceにさらに多くの値を導入することは可能ですか?

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 を作成することにより、具体化後に要素を追加できる Source の作成について言及しているように。

アッカのドキュメント:

1 に答える 1