akka - 是否可以加入 Akka Streams Source 的元素？

Question

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

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

是否可以在特定的分隔符模式上加入和重新拆分元素，例如在 '\n' 字符上以产生类似的结果？：

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

谢谢！

Answer 1

这可以使用框架来完成：

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