Package akka.stream.scaladsl

Class MergeHub<T>

java.lang.Object

akka.stream.stage.GraphStageWithMaterializedValue<SourceShape<T>,scala.Tuple2<Sink<T,NotUsed>,MergeHub.DrainingControl>>

akka.stream.scaladsl.MergeHub<T>

All Implemented Interfaces:

Graph<SourceShape<T>,scala.Tuple2<Sink<T,NotUsed>,MergeHub.DrainingControl>>

public class MergeHub<T>
extends GraphStageWithMaterializedValue<SourceShape<T>,scala.Tuple2<Sink<T,NotUsed>,MergeHub.DrainingControl>>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	MergeHub.DrainingControl	A DrainingControl object is created during the materialization of a MergeHub and allows to initiate the draining and eventual completion of the Hub from the outside.
static interface	MergeHub.Event
class	MergeHub.InputState
class	MergeHub.MergedSourceLogic
static class	MergeHub.ProducerFailed

Nested classes/interfaces inherited from interface akka.stream.Graph

Graph.GraphMapMatVal<S extends Shape,M>

Constructor Summary

Constructors

Constructor	Description
MergeHub(int perProducerBufferSize, boolean drainingEnabled)

Method Summary

Modifier and Type	Method	Description
static <T> boolean	$lessinit$greater$default$2()	INTERNAL API
scala.Tuple2<GraphStageLogic,scala.Tuple2<Sink<T,NotUsed>,MergeHub.DrainingControl>>	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()
static <T> Source<T,Sink<T,NotUsed>>	source(int perProducerBufferSize)
static <T> Source<T,scala.Tuple2<Sink<T,NotUsed>,MergeHub.DrainingControl>>	sourceWithDraining()
static <T> Source<T,scala.Tuple2<Sink<T,NotUsed>,MergeHub.DrainingControl>>	sourceWithDraining(int perProducerBufferSize)

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,
                boolean drainingEnabled)

Method Detail

$lessinit$greater$default$2

public static <T> boolean $lessinit$greater$default$2()

INTERNAL API

source

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

sourceWithDraining

public static <T> Source<T,scala.Tuple2<Sink<T,NotUsed>,MergeHub.DrainingControl>> sourceWithDraining(int perProducerBufferSize)

source

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

sourceWithDraining

public static <T> Source<T,scala.Tuple2<Sink<T,NotUsed>,MergeHub.DrainingControl>> sourceWithDraining()

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.

createLogicAndMaterializedValue

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

Specified by:

createLogicAndMaterializedValue in class GraphStageWithMaterializedValue<SourceShape<T>,scala.Tuple2<Sink<T,NotUsed>,MergeHub.DrainingControl>>