Package akka.stream.scaladsl

Class MergeHub<T>

java.lang.Object

akka.stream.stage.GraphStageWithMaterializedValue<SourceShape<T>,Sink<T,NotUsed>>

akka.stream.scaladsl.MergeHub<T>

All Implemented Interfaces:

Graph<SourceShape<T>,Sink<T,NotUsed>>

public class MergeHub<T>
extends GraphStageWithMaterializedValue<SourceShape<T>,Sink<T,NotUsed>>

INTERNAL API

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	MergeHub.Event
class	MergeHub.InputState
class	MergeHub.MergedSourceLogic
static class	MergeHub.ProducerFailed

Constructor Summary

Constructors

Constructor	Description
MergeHub(int perProducerBufferSize)

Method Summary

Modifier and Type	Method	Description
scala.Tuple2<GraphStageLogic,Sink<T,NotUsed>>	createLogicAndMaterializedValue(Attributes inheritedAttributes)
Outlet<T>	out()
SourceShape<T>	shape()	The shape of a graph is all that is externally visible: its inlets and outlets.
static <T> Source<T,Sink<T,NotUsed>>	source()	Creates a Source that emits elements merged from a dynamic set of producers.
static <T> Source<T,Sink<T,NotUsed>>	source(int perProducerBufferSize)	Creates a Source that emits elements merged from a dynamic set of producers.

Methods inherited from class akka.stream.stage.GraphStageWithMaterializedValue

createLogicAndMaterializedValue, initialAttributes, traversalBuilder, withAttributes

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface akka.stream.Graph

addAttributes, async, async, async, named

Constructor Detail

MergeHub

public MergeHub(int perProducerBufferSize)

Method Detail

source

public static <T> Source<T,Sink<T,NotUsed>> source(int perProducerBufferSize)

Creates a Source that emits elements merged from a dynamic set of producers. After the Source returned by this method is materialized, it returns a Sink as a materialized value. This Sink can be materialized arbitrary many times and each of the materializations will feed the elements into the original Source.

Every new materialization of the Source results in a new, independent hub, which materializes to its own Sink for feeding that materialization.

Completed or failed Sinks are simply removed. Once the Source is cancelled, the Hub is considered closed and any new producers using the Sink will be cancelled.

Parameters:

perProducerBufferSize - Buffer space used per producer. Default value is 16.

Returns:

(undocumented)

source

public static <T> Source<T,Sink<T,NotUsed>> source()

Creates a Source that emits elements merged from a dynamic set of producers. After the Source returned by this method is materialized, it returns a Sink as a materialized value. This Sink can be materialized arbitrary many times and each of the materializations will feed the elements into the original Source.

Every new materialization of the Source results in a new, independent hub, which materializes to its own Sink for feeding that materialization.

Completed or failed Sinks are simply removed. Once the Source is cancelled, the Hub is considered closed and any new producers using the Sink will be cancelled.

Returns:

(undocumented)

out

public Outlet<T> out()

shape

public SourceShape<T> shape()

Description copied from interface: Graph

The shape of a graph is all that is externally visible: its inlets and outlets.

Returns:

(undocumented)

createLogicAndMaterializedValue

public scala.Tuple2<GraphStageLogic,Sink<T,NotUsed>> createLogicAndMaterializedValue(Attributes inheritedAttributes)

Specified by:

createLogicAndMaterializedValue in class GraphStageWithMaterializedValue<SourceShape<T>,Sink<T,NotUsed>>