Package akka.stream.javadsl
Class MergeHub
- java.lang.Object
-
- akka.stream.javadsl.MergeHub
-
public class MergeHub extends java.lang.ObjectCreates aSourcethat emits elements merged from a dynamic set of producers. After theSourcereturned by this method is materialized, it returns aSinkas a materialized value. ThisSinkcan be materialized arbitrary many times and each of the materializations will feed the elements into the originalSource.Every new materialization of the
Sourceresults in a new, independent hub, which materializes to its ownSinkfor feeding that materialization.Completed or failed
Sinks are simply removed. Once theSourceis cancelled, the Hub is considered closed and any new producers using theSinkwill be cancelled.param: clazz Type of elements this hub emits and consumes param: perProducerBufferSize Buffer space used per producer.
-
-
Constructor Summary
Constructors Constructor Description MergeHub()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <T> Source<T,Sink<T,NotUsed>>of(java.lang.Class<T> clazz)Creates aSourcethat emits elements merged from a dynamic set of producers.static <T> Source<T,Sink<T,NotUsed>>of(java.lang.Class<T> clazz, int perProducerBufferSize)
-
-
-
Method Detail
-
of
public static <T> Source<T,Sink<T,NotUsed>> of(java.lang.Class<T> clazz, int perProducerBufferSize)
-
of
public static <T> Source<T,Sink<T,NotUsed>> of(java.lang.Class<T> clazz)
Creates aSourcethat emits elements merged from a dynamic set of producers. After theSourcereturned by this method is materialized, it returns aSinkas a materialized value. ThisSinkcan be materialized arbitrary many times and each of the materializations will feed the elements into the originalSource.Every new materialization of the
Sourceresults in a new, independent hub, which materializes to its ownSinkfor feeding that materialization.Completed or failed
Sinks are simply removed. Once theSourceis cancelled, the Hub is considered closed and any new producers using theSinkwill be cancelled.- Parameters:
clazz- Type of elements this hub emits and consumes- Returns:
- (undocumented)
-
-