Replies: 1 comment
-
I start the discussion in the email list, close now |
Beta Was this translation helpful? Give feedback.
0 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Uh oh!
There was an error while loading. Please reload this page.
Uh oh!
There was an error while loading. Please reload this page.
-
Refs: akka/akka#28327
I just made a PR in akka/akka, which added a
startAfterNrOfConsumers
toBroadcastHub
. And surely I will send the PR to pekko too.I think we should make the current
BroadcastHub.sink[T]
withBroadcastHub.sink[T] = BroadcastHub.sink(startAfterNrOfConsumers = 1, defaultBufferSize)
in pekko by default, which is0
now.Beta Was this translation helpful? Give feedback.
All reactions