Hi I'm implementing a TCP protocol (Lumberjack2/Beats) in Akka Streams. It is a streaming application level protocol where each messages varies data length. In Akka streams I get ByteStrings fed through the stream but I can't find any information about how these correlate with TCP packets sent over wire. Without that knowledge I have to create a buffer for partial message and handle all theoretical cases that could occur when ByteString does not correlate 1:1 with TCP payloads. The resulting implementation becomes quite hairy.
1. What are the guarantees around correlation between Akka ByteStrings and TCP packets? 2. Examples of TCP protocols implemented with Akka streams that uses dynamic framing examples? /Magnus -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
