public class BroadcastHub$ extends java.lang.ObjectA BroadcastHub is a special streaming hub that is able to broadcast streamed elements to a dynamic set of consumers. It consists of two parts, a
Sinkbroadcasts elements from a producer to the actually live consumers it has. Once the producer has been materialized, the
Sinkit feeds into returns a materialized value which is the corresponding
Sourcecan be materialized an arbitrary number of times, where each of the new materializations will receive their elements from the original
Constructors Constructor Description
All Methods Instance Methods Concrete Methods Modifier and Type Method Description
of(java.lang.Class<T> clazz, int bufferSize)Creates a
Sinkthat receives elements from its upstream producer and broadcasts them to a dynamic set of consumers.
public static final BroadcastHub$ MODULE$Static reference to the singleton instance of this Scala object.
Sinkthat receives elements from its upstream producer and broadcasts them to a dynamic set of consumers. After the
Sinkreturned by this method is materialized, it returns a
Sourceas materialized value. This
Sourcecan be materialized an arbitrary number of times and each materialization will receive the broadcast elements from the original
If the original
Sinkis failed, then the failure is immediately propagated to all of its materialized
Sources (possibly jumping over already buffered elements). If the original
Sinkis completed, then all corresponding
Sources are completed. Both failure and normal completion is "remembered" and later materializations of the
Sourcewill see the same (failure or completion) state.
Sources that are cancelled are simply removed from the dynamic set of consumers.
clazz- Type of elements this hub emits and consumes
bufferSize- 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.