我正在使用 akka 流从 TCP 端点消耗
ByteString
s 流。数据块应该形成一个或多个 XML 文档。我希望我的流输出带有完整 Xml 的ByteString
s。
例如这样的来源
Source(List(
"<Update1></Update1><Update2></Update2>",
"<Update3>",
"</Update3>"
))
附加到这个流应该实现:
List(
"<Update1></Update1>",
"<Update2></Update2>",
"<Update3></Update3>"
)
(为简单起见,我现在将字符串包装为 ByteString)。