Refs: akka/akka#28327 <https://github.com/akka/akka/issues/28327>

We can add a startAfterNrOfConsumers to BroadcastHub.

I think we should make the current BroadcastHub.sink[T] with
BroadcastHub.sink[T]
= BroadcastHub.sink(startAfterNrOfConsumers = 1, defaultBufferSize) in
pekko by default, which is 0 now.

https://stackoverflow.com/questions/58974630/broadcasthub-doesnt-wait-for-first-materialization-of-source

何品

Reply via email to