如何解决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 举报,一经查实,本站将立刻删除。