Akka Streams处理实体的子序列

问题描述

我正在尝试创建一个流来处理具有顺序字段的项目。 假设

case class Entity (sub: Seq[SubEntity]) 

在流的某个点，应该处理这些“子”。

我不认为创建另一个图形是一种选择。因此，根据我的理解，这是一个不好的方法：

Flow[Entity]
  .map({ entity  ⇒
    Source(entity.subs)
      .map({sub ⇒ 
        // do stuff
      })
      .run

      subs = // ... collect things subs
      entity.copy(subs = subs)
  })

将子序列的处理放入常规流中的正确方法是什么？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）