ストリーム内でAkkaストリームを作成して開始する方法

Question

いくつかのメッセージを処理するakkaストリームがあります。イベントが発生すると、ストリームは別のakkaストリームの新しいインスタンスを作成するはずです。

これは私がやっていることです。これが最善の方法ですか？

if(event.happened) new AnalysisFlow(info.id,info.time).flow 

おかげ

Answer 1

eventは、ストリームの一部である場合は、サブにあなたのストリームを分割するgroupByを使用することができるかもしれません。

flatMapConcatまたはflatMapMergeを使用して、ストリームをSourceのストリームに変換することもできます。このストリームは、連結またはマージ戦略を使用して実行および平準化されます。