如何在流內創建並啓動Akka流

Question

我有一個處理某些消息的akka​​流。當一個事件發生時，流應該創建一個不同的阿卡流的新實例。

目前這是我正在做的。這是最好的方法嗎？

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

感謝

Answer 1

如果event是物流的一部分，你也許可以使用groupBy你流拆分成子。

您也可以使用flatMapConcat或flatMapMerge將您的元素流轉換爲Source的流，然後使用concat或合併策略相應地運行和展平。