akka.stream.scaladsl

Class MergeHub.MergedSourceLogic

java.lang.Object

akka.stream.stage.GraphStageLogic

akka.stream.scaladsl.MergeHub.MergedSourceLogic

All Implemented Interfaces:

OutHandler

Enclosing class:

MergeHub<T>

public final class MergeHub.MergedSourceLogic
extends GraphStageLogic
implements OutHandler

Nested Class Summary

Nested classes/interfaces inherited from class akka.stream.stage.GraphStageLogic

GraphStageLogic.ConditionalTerminateInput, GraphStageLogic.ConditionalTerminateOutput, GraphStageLogic.EagerTerminateInput$, GraphStageLogic.EagerTerminateOutput$, GraphStageLogic.IgnoreTerminateInput$, GraphStageLogic.IgnoreTerminateOutput$, GraphStageLogic.StageActor, GraphStageLogic.StageActorRef$, GraphStageLogic.StageActorRefNotInitializedException, GraphStageLogic.StageActorRefNotInitializedException$, GraphStageLogic.SubSinkInlet<T>, GraphStageLogic.SubSourceOutlet<T>, GraphStageLogic.TotallyIgnorantInput$

Constructor Summary

Constructors

Constructor and Description
MergedSourceLogic(SourceShape<T> _shape, java.util.concurrent.atomic.AtomicLong producerCount)

Method Summary

Modifier and Type	Method and Description
void	enqueue(akka.stream.scaladsl.MergeHub.Event ev)
boolean	isShuttingDown()
void	onPull() Called when the output port has received a pull, and therefore ready to emit an element, i.e.
void	postStop() Invoked after processing of external events stopped because the stage is about to stop or fail.

Methods inherited from class akka.stream.stage.GraphStageLogic

abortEmitting, abortReading, afterPostStop, beforePreStart, cancel, complete, completeStage, conditionalTerminateInput, conditionalTerminateOutput, createAsyncCallback, eagerTerminateInput, eagerTerminateOutput, emit, emit, emit, emitMultiple, emitMultiple, emitMultiple, emitMultiple, emitMultiple, emitMultiple, fail, failStage, getAsyncCallback, getHandler, getHandler, getStageActor, grab, handlers, hasBeenPulled, ignoreTerminateInput, ignoreTerminateOutput, inCount, interpreter, isAvailable, isAvailable, isClosed, isClosed, materializer, outCount, passAlong, portToConn, preStart, pull, push, read, read, readN, readN, setHandler, setHandler, setHandlers, setKeepGoing, stageActor, stageId, subFusingMaterializer, totallyIgnorantInput, tryPull

Methods inherited from class java.lang.Object

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

Methods inherited from interface akka.stream.stage.OutHandler

onDownstreamFinish

Constructor Detail

MergedSourceLogic

public MergedSourceLogic(SourceShape<T> _shape,
                         java.util.concurrent.atomic.AtomicLong producerCount)

Method Detail

onPull

public void onPull()

Description copied from interface: OutHandler

Called when the output port has received a pull, and therefore ready to emit an element, i.e. GraphStageLogic.push() is now allowed to be called on this port.

Specified by:

onPull in interface OutHandler

isShuttingDown

public boolean isShuttingDown()

enqueue

public void enqueue(akka.stream.scaladsl.MergeHub.Event ev)

postStop

public void postStop()

Description copied from class: GraphStageLogic

Invoked after processing of external events stopped because the stage is about to stop or fail.

Overrides:

postStop in class GraphStageLogic