我正在尝试想出一种解决方案,将我接收到的字符串拆分为多个字符串。我已经进行了研究,看起来在之前的Akka-Streams版本中有一个名为Transformer
的类,你可以扩展它来完成这种转换。
在我使用的版本(RC2)中,有Stage
,但我不太确定如何实现拆分模式。
Source.actorPublisher[String](MyActor.props).
.XXXXX(_.split("\n"))
.map(...)
.to(Sink(...))
我正在寻找一个组件XXXXX
,它可以允许我输入一个String
并返回一系列String
,并将每个String
发送到其余的流中。
mapConcat
。如果依赖关系更复杂,则可以使用(有状态的)阶段。 - jrudolphmapConcat
可以被视为flatMap
的一种形式。名称不同是因为某些单子律不成立。 - almendar