Hello,
I am a newbie trying to understand Akka Streams.
Coming from regular socket programming I am trying to mimic a client
connection and have the following runnable graph.
Flow flow
= Tcp
Suppose I use an *Adaptive Load Balancing Router* in an actor subscriber as
partially demonstrated in the akka stream documentation, is this in effect
providing back pressure for all my routee actors to ensure that they aren't
overwhelm with messages? And that the worker pool actor subscriber
That seems like a good catch indeed!
Thanks for finding this.
I've made an issue and PR for it:
https://github.com/akka/akka/issues/21077
https://github.com/akka/akka/pull/21078
If reviewed by team we could include this patch very soon.
Thanks for reporting!
-- Konrad
W dniu czwartek, 28
Typo on my last comment; meant to say I 'used' the existing Akka Graph DSL.
(Definitely didn't write my own!)
On Friday, July 15, 2016 at 9:03:05 AM UTC-7, Maatary Okouya wrote:
>
> Hi,
>
> given that Longom is not working to Scala anytime soon. I wonder if
> someone could share with some