【问题标题】:Is it possible to join elements of an Akka Streams Source?是否可以加入 Akka Streams Source 的元素?
【发布时间】:2016-02-04 07:00:42
【问题描述】:

如果我有像他这样的来源:

val source = Source(List("hell", "o\n my ", "name is bob"))

是否可以在特定的分隔符模式上连接和重新拆分元素,例如在 '\n' 字符上以产生类似的结果? :

Source(List("hello", "my name is bob"))

谢谢!

【问题讨论】:

    标签: akka akka-stream reactive-streams


    【解决方案1】:

    这可以使用框架来完成:

    source.via(Framing.delimiter(ByteString("\n"), maximumFrameLength = 100, allowTruncation = true))
    

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 2020-08-14
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2016-01-21
      • 1970-01-01
      • 1970-01-01
      相关资源
      最近更新 更多