Class MergeHub$
- java.lang.Object
-
- akka.stream.scaladsl.MergeHub$
-
public class MergeHub$ extends java.lang.Object
Creates aSource
that emits elements merged from a dynamic set of producers. After theSource
returned by this method is materialized, it returns aSink
as a materialized value. ThisSink
can be materialized arbitrary many times and each of the materializations will feed the elements into the originalSource
.Every new materialization of the
Source
results in a new, independent hub, which materializes to its ownSink
for feeding that materialization.Completed or failed
Sink
s are simply removed. Once theSource
is cancelled, the Hub is considered closed and any new producers using theSink
will be cancelled.param: perProducerBufferSize Buffer space used per producer. Default value is 16.
-
-
Constructor Summary
Constructors Constructor Description MergeHub$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <T> Source<T,Sink<T,NotUsed>>
source()
Creates aSource
that emits elements merged from a dynamic set of producers.<T> Source<T,Sink<T,NotUsed>>
source(int perProducerBufferSize)
Creates aSource
that emits elements merged from a dynamic set of producers.
-
-
-
Field Detail
-
MODULE$
public static final MergeHub$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
source
public <T> Source<T,Sink<T,NotUsed>> source(int perProducerBufferSize)
Creates aSource
that emits elements merged from a dynamic set of producers. After theSource
returned by this method is materialized, it returns aSink
as a materialized value. ThisSink
can be materialized arbitrary many times and each of the materializations will feed the elements into the originalSource
.Every new materialization of the
Source
results in a new, independent hub, which materializes to its ownSink
for feeding that materialization.Completed or failed
Sink
s are simply removed. Once theSource
is cancelled, the Hub is considered closed and any new producers using theSink
will be cancelled.- Parameters:
perProducerBufferSize
- Buffer space used per producer. Default value is 16.- Returns:
- (undocumented)
-
source
public <T> Source<T,Sink<T,NotUsed>> source()
Creates aSource
that emits elements merged from a dynamic set of producers. After theSource
returned by this method is materialized, it returns aSink
as a materialized value. ThisSink
can be materialized arbitrary many times and each of the materializations will feed the elements into the originalSource
.Every new materialization of the
Source
results in a new, independent hub, which materializes to its ownSink
for feeding that materialization.Completed or failed
Sink
s are simply removed. Once theSource
is cancelled, the Hub is considered closed and any new producers using theSink
will be cancelled.- Returns:
- (undocumented)
-
-