In case it helps: https://groups.google.com/d/topic/akka-user/AgVHHnl9ub4/discussion https://github.com/akka/akka/issues/22742
On Fri, May 26, 2017 at 1:34 PM, Curt Siffert <[email protected]> wrote: > > Hi, I see in the docs for 2.5.2 that ActorPublisher/ActorSubscriber will > be deprecated. > > In my (still beginning) experiments with akka streams I used > ActorPublisher as a way to help create some back pressure controls while > consuming messages from an external queue. This worked just by consuming > the queue like normal and then for each message consumed, sending a message > to ActorPublisher. > > Without using ActorPublisher, I can use a Source.actorRef, but that > doesn't have back pressure controls. > > I know the recommended alternative to ActorPublisher is to use a custom > graph stage and I have started experimenting with that but so far I don't > see how to meet the ActorPublisher use case with it. So far it doesn't seem > like a custom Source has an ActorRef type signature like Source.actorRef > does. Once the custom stage is created, can I send a "tell" message to it > the way I did to ActorPublisher? Or am I supposed to use Source.actorRef > and then funnel it through the custom stage to get the back pressure > controls? > > Sorry if my question is muddled, I am still making my way through this. > :-) I recognize this is a bit weird since ideally the back pressure > controls would be applied to the queueing tech itself. > > Curt > > -- > >>>>>>>>>> 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 [email protected]. > To post to this group, send email to [email protected]. > Visit this group at https://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 [email protected]. To post to this group, send email to [email protected]. Visit this group at https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
