akka - 在 Akka-Streams 中拆分流

Question

我正在尝试提出一种解决方案，将我接收到的传入字符串拆分为多个字符串。我一直在研究，看起来在以前版本的 Akka-Streams 中有一个 Transformer 类，您可以扩展它来进行这种转换。

在我使用的版本 (RC2) 中有 Stage，但我不确定如何实现拆分模式。

Source.actorPublisher[String](MyActor.props).
.XXXXX(_.split("\n"))
.map(...)
.to(Sink(...))

我正在寻找 XXXXX 组件，它允许我输入一个 String 并返回一个 String 序列，并将发出每个到流程的其余部分。

Answer 1

我同意@jrudolph 的观点，mapConcat 可能是您正在寻找的。一个简单的例子展示了这个方法的实际应用:

  val strings = List(
  """hello
     world
     test
     this""",
     """foo
     bar
     baz
     """

  )

  implicit val system = ActorSystem("test")
  implicit val mater = ActorFlowMaterializer()
  Source(strings).
    mapConcat(_.split("\n").map(_.trim).toList).
    runForeach(println)

如果您运行这段代码，您将看到打印出以下内容:

hello
world
test
this
foo     
bar
baz