Hi Adam
> - is it reasonable (thinking about reactive streams in general) to have an > actor which produces elements on-demand (instead of providing a > collection/iterator/() => as is currently supported)? As far as I > understand the current implementation, subscribers explicitly ask > publishers for more elements (through Subscription.requestMore) - so it > seems it would be possible to pass such a request to an actor and ask for > the given amount of elements. Is there any chance to get "actor producers" > in some future releases, or there are no such plans currently? > > There is already one bridge to build consumers based on actors: https://github.com/akka/akka/pull/15214 The producer side is still missing, but there will be something to support that as well. > - 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. > 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. -Endre > > Thanks! > > -- > 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. > -- >>>>>>>>>> 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.
