如何在流中创建和启动 Akka 流答案

【问题标题】：How to create and start an Akka stream inside a stream如何在流中创建和启动 Akka 流
【发布时间】：2016-04-25 22:53:48
【问题描述】：

我有一个处理一些消息的 akka 流。当事件发生时，流应该创建不同 akka 流的新实例。

目前这就是我正在做的事情。这是最好的方法吗？

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

谢谢

【问题讨论】：

【解决方案1】：

如果event 是流的一部分，您或许可以使用groupBy 将流拆分为子流。

您还可以使用flatMapConcat 或flatMapMerge 将您的元素流转换为Sources 流，然后相应地使用 concat 或合并策略运行和展平。

【讨论】：