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 lipc
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 w
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
.get(system).outgoingConnection("127.0.0.1", 6000);
Source clientSourc
Hi ,
In Akka Stream is it possible to create custom windows.
For example
case class Source1(id: Int, data: Int)
case class Source2(id: Int, data: Int)
case class Combined(id: Int, data: (Int,Int))
val source1Iter = for (i <- 1 to 100) yield Source1(i, r.nextInt(11))
val source2Iter = for (i