Howdie, I'm wondering if it's possible to implement my use case and what the best implementation of that might look like.
I'd like to have a bi-directional set of channel messages chunked independently and multiplexed across a TCP connection. Something that looks like this: ChannelMessage(id: Long, msg: Any) <--> ChannelByteString(id: Long, bytes: ByteString) <--> Seq[ByteString] <--> // The ChannelByteString chunked up TCP The chunking and serializing is clear to me and I've got a pipeline for that now. What I'm lost on is the dynamic nature of the channels; the TCP connection is set up ahead of time, and then parties on either end of it negotiate a temporary channel on which they can communicate within it. i.e. there's plexing going on in there. Fan-In and Fan-Out seem to be entirely appropriate to solve this problem, but... I don't want a 1->n or n->1 where n is fixed. I need n to be a variable. What's the best way to do this? Am I looking to using Actors to solve this problem, something more like this: ChannelMessage(id: Long, msg: Any) <--> ChannelByteString(id: Long, bytes: ByteString) <--> === Actor bridge in here that can install and remove channels === Seq[ByteString] <--> // The ChannelByteString chunked up TCP Thanks a lot. It really looks like streams have come a very long way since I last looked. I haven't wrapped my head around them very well as of yet, but I definitely have a feel of the power in them. Bravo :) Cheers, Derek -- >>>>>>>>>> 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.