This seems ok for v1.0.0 Pekko to me. It is a new function (at least, a separate overloaded version of the existing function).
Existing Akka users can migrate and use the equivalent function or they can switch to the overloaded alternative function. This seems to be a tidy migration path to me. On Thu, 23 Mar 2023 at 17:24, kerr <hepin1...@gmail.com> wrote: > > 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 > > 何品 --------------------------------------------------------------------- To unsubscribe, e-mail: dev-unsubscr...@pekko.apache.org For additional commands, e-mail: dev-h...@pekko.apache.org
