Hey Adam, Patrik has right now opened a ticket and started exposing the ActorProducer abstraction :-) https://github.com/akka/akka/issues/15288 This will help a lot in implementing external producers. :-)
On Mon, May 26, 2014 at 2:52 PM, Endre Varga <endre.va...@typesafe.com>wrote: > 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. > -- Cheers, Konrad 'ktoso' Malawski hAkker - Typesafe, Inc <http://scaladays.org> -- >>>>>>>>>> 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.
