Only a 10s look and I'm in a rush. But I'm guessing the 'new Chunker()' is where you want to start. In order for any chunker to process across message boundaries it'll need to have some type of "memory" and getting a new one each time probably won't accomplish that.
Now either the Chunker can already do this and we're calling it wrong, or you could write your own custom stage. There are doc examples of filters and duplicators, etc. You could write a custom stage that maintained an internal buffer and would chunk and send, or possibly partially fill and wait. When new messages show up, fill and send. If you're partially full but the stream ends, send your partial buffer. -- >>>>>>>>>> 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 akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
