akka-stream

10熱度

4回答

如何使用Akka Streams在分隔符上分割入站流

我一直在玩Akka Streams API實驗，我有一個用例，我想看看如何實現。對於我的用例，我有一個StreamTcp基於Flow，它是通過將連接的輸入流綁定到我的服務器套接字來提供的。我擁有的Flow基於ByteString數據。進入的數據將會有一個分隔符，這意味着我應該將分隔符之前的所有內容作爲一條消息進行處理，並將所有分隔符之後的所有內容作爲下一條消息進行處理。所以，玩弄一個簡單的例子，不

scala akka akka-stream 2014-09-02

---