Ah, good factoid! Thanks!
Brian Maso
On Mon, Apr 13, 2020, 03:29 Alexey Shuksto wrote:
> > To be honest I'm not sure of how messages are handled when there are no
> active Source[T] instances consuming messages sent to Broadcast.sink[T]...
> > My impression is that they would be thrown away, an
> To be honest I'm not sure of how messages are handled when there are no
active Source[T] instances consuming messages sent to Broadcast.sink[T]...
> My impression is that they would be thrown away, and the bufferSize
parameter to BroadcastHub.sink[T] only comes into play when there are one
or
I suggest you post your question on the gitter channel (gitter.im/akka/akka).
There are a lot of knowledgeable people who can answer, and I think it is a
much more active space than this (deprecated) list.
But to answer your question: the materialized value of an asynchronous Sink
is a Future[T].
Hi all,
I've been looking at MergeHub and BroadcastHub for Akka Stream and I am a
bit confused.
In the beginning of the documentation the following is mentioned:
It is important to remember that even after constructing the RunnableGraph
> by connecting all the source, sink and different oper
