> > > - another thing is if the streams are thought to be more local, or remote >> as well? There's currently the TCP stream implementation, which I guess >> would indicate remote as well (and in such scenarios the need for >> backpressure arises quite naturally, maybe even more than in locally), but >> do you plan to develop this somehow? >> > > Streaming through TCP is already remote, so in that sense it is already > supported. Of course you need to open up the connections yourself now, and > there is no "registry" or "naming" functionality to obtain remote stream > endpoints. >
Right, but I guess naming/lookup is out of scope for akka-stream? I guess I was asking whether your initial focus is going to be on local or remote, but I think Konrad already answered that :) > E.g. when there would be multiple consumers for a single producer, a >> useful component would be a load-balancer which takes into account the >> backpressure information. >> > > All stream components take into account backpressure signal independently > of fan-in or fan-out behavior, so this is by default available. (we do not > have balancing elements yet, but they will be there eventually. Workaround > can be a groupBy assigning to a fixed number of output groups randomly, but > this is a bit dangerous field). From the stream viewpoint it does not > matter whether the output streams are local or TCP connections, the > balancing should work exactly the same way. > So right now you have "broadcast" communication implemented when there are multiple consumers. The other pattern is point-to-point, where each element goes to one of the attached consumers - where load-balancing would make sense (as you have the demand information, you could do very good guesses :) ). Anyway, I'll be watching the developments here :) Also with Actor producers, I think it would be quite easy to implement such a load-balancer: for each consumer, you would have an actor-producer, which would report the demand to a parent actor, where the load-balancing would take place. Thanks for the info! Adam -- >>>>>>>>>> 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.
