Class BroadcastHub$
- java.lang.Object
-
- akka.stream.javadsl.BroadcastHub$
-
public class BroadcastHub$ extends java.lang.Object
A BroadcastHub is a special streaming hub that is able to broadcast streamed elements to a dynamic set of consumers. It consists of two parts, aSink
and aSource
. TheSink
broadcasts elements from a producer to the actually live consumers it has. Once the producer has been materialized, theSink
it feeds into returns a materialized value which is the correspondingSource
. ThisSource
can be materialized an arbitrary number of times, where each of the new materializations will receive their elements from the originalSink
.
-
-
Field Summary
Fields Modifier and Type Field Description static BroadcastHub$
MODULE$
Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description BroadcastHub$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <T> Sink<T,Source<T,NotUsed>>
of(java.lang.Class<T> clazz)
Creates aSink
with default buffer size 256 that receives elements from its upstream producer and broadcasts them to a dynamic set of consumers.<T> Sink<T,Source<T,NotUsed>>
of(java.lang.Class<T> clazz, int bufferSize)
Creates aSink
that receives elements from its upstream producer and broadcasts them to a dynamic set of consumers.
-
-
-
Field Detail
-
MODULE$
public static final BroadcastHub$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
of
public <T> Sink<T,Source<T,NotUsed>> of(java.lang.Class<T> clazz, int bufferSize)
Creates aSink
that receives elements from its upstream producer and broadcasts them to a dynamic set of consumers. After theSink
returned by this method is materialized, it returns aSource
as materialized value. ThisSource
can be materialized an arbitrary number of times and each materialization will receive the broadcast elements from the originalSink
.Every new materialization of the
Sink
results in a new, independent hub, which materializes to its ownSource
for consuming theSink
of that materialization.If the original
Sink
is failed, then the failure is immediately propagated to all of its materializedSource
s (possibly jumping over already buffered elements). If the originalSink
is completed, then all correspondingSource
s are completed. Both failure and normal completion is "remembered" and later materializations of theSource
will see the same (failure or completion) state.Source
s that are cancelled are simply removed from the dynamic set of consumers.- Parameters:
clazz
- Type of elements this hub emits and consumesbufferSize
- Buffer size used by the producer. Gives an upper bound on how "far" from each other two concurrent consumers can be in terms of element. If the buffer is full, the producer is backpressured. Must be a power of two and less than 4096.
-
of
public <T> Sink<T,Source<T,NotUsed>> of(java.lang.Class<T> clazz)
Creates aSink
with default buffer size 256 that receives elements from its upstream producer and broadcasts them to a dynamic set of consumers. After theSink
returned by this method is materialized, it returns aSource
as materialized value. ThisSource
can be materialized an arbitrary number of times and each materialization will receive the broadcast elements from the originalSink
.Every new materialization of the
Sink
results in a new, independent hub, which materializes to its ownSource
for consuming theSink
of that materialization.If the original
Sink
is failed, then the failure is immediately propagated to all of its materializedSource
s (possibly jumping over already buffered elements). If the originalSink
is completed, then all correspondingSource
s are completed. Both failure and normal completion is "remembered" and later materializations of theSource
will see the same (failure or completion) state.Source
s that are cancelled are simply removed from the dynamic set of consumers.- Parameters:
clazz
- Type of elements this hub emits and consumes
-
-