Package akka.stream.impl.fusing

Class ActorGraphInterpreter.BatchingActorInputBoundary

java.lang.Object

akka.stream.stage.GraphStageLogic

akka.stream.impl.fusing.GraphInterpreter.UpstreamBoundaryStageLogic<java.lang.Object>

akka.stream.impl.fusing.ActorGraphInterpreter.BatchingActorInputBoundary

All Implemented Interfaces:

OutHandler

Enclosing class:

ActorGraphInterpreter

public static class ActorGraphInterpreter.BatchingActorInputBoundary
extends GraphInterpreter.UpstreamBoundaryStageLogic<java.lang.Object>
implements OutHandler

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	ActorGraphInterpreter.BatchingActorInputBoundary.OnComplete
class	ActorGraphInterpreter.BatchingActorInputBoundary.OnComplete$
class	ActorGraphInterpreter.BatchingActorInputBoundary.OnError
class	ActorGraphInterpreter.BatchingActorInputBoundary.OnError$
class	ActorGraphInterpreter.BatchingActorInputBoundary.OnNext
class	ActorGraphInterpreter.BatchingActorInputBoundary.OnNext$
class	ActorGraphInterpreter.BatchingActorInputBoundary.OnSubscribe
class	ActorGraphInterpreter.BatchingActorInputBoundary.OnSubscribe$

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	Description
BatchingActorInputBoundary(int size, GraphInterpreterShell shell, org.reactivestreams.Publisher<java.lang.Object> publisher, java.lang.String internalPortName)

Method Summary

Modifier and Type	Method	Description
void	cancel()
void	onComplete()
ActorGraphInterpreter.BatchingActorInputBoundary.OnComplete$	OnComplete()
void	onDownstreamFinish()	Called when the output port will no longer accept any new elements.
void	onError(java.lang.Throwable e)
ActorGraphInterpreter.BatchingActorInputBoundary.OnError$	OnError()
void	onInternalError(java.lang.Throwable e)
void	onNext(java.lang.Object elem)
ActorGraphInterpreter.BatchingActorInputBoundary.OnNext$	OnNext()
void	onPull()	Called when the output port has received a pull, and therefore ready to emit an element, i.e.
void	onSubscribe(org.reactivestreams.Subscription subscription)
ActorGraphInterpreter.BatchingActorInputBoundary.OnSubscribe$	OnSubscribe()
Outlet<java.lang.Object>	out()
void	preStart()	Invoked before any external events are processed, at the startup of the operator.
void	setActor(ActorRef actor)
java.lang.String	toString()

Methods inherited from class akka.stream.stage.GraphStageLogic

abortEmitting, abortReading, afterPostStop, attributes, attributes_$eq, beforePreStart, cancel, cancelStage, complete, completeStage, conditionalTerminateInput, conditionalTerminateOutput, createAsyncCallback, eagerTerminateInput, eagerTerminateOutput, emit, emit, emit, emitMultiple, emitMultiple, emitMultiple, emitMultiple, emitMultiple, emitMultiple, fail, failStage, getAsyncCallback, getEagerStageActor, getHandler, getHandler, getStageActor, grab, handlers, hasBeenPulled, ignoreTerminateInput, ignoreTerminateOutput, inCount, inHandler, interpreter, interpreter_$eq, isAvailable, isAvailable, isClosed, isClosed, materializer, NoPromise, onFeedbackDispatched, originalStage, originalStage_$eq, outCount, outHandler, passAlong, passAlong$default$3, passAlong$default$4, passAlong$default$5, portToConn, postStop, pull, push, read, read, readN, readN, setHandler, setHandler, setHandlers, setKeepGoing, stageActor, stageActorName, stageId, stageId_$eq, subFusingMaterializer, totallyIgnorantInput, tryPull

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchingActorInputBoundary

public BatchingActorInputBoundary(int size,
                                  GraphInterpreterShell shell,
                                  org.reactivestreams.Publisher<java.lang.Object> publisher,
                                  java.lang.String internalPortName)

Method Detail

OnComplete

public ActorGraphInterpreter.BatchingActorInputBoundary.OnComplete$ OnComplete()

OnError

public ActorGraphInterpreter.BatchingActorInputBoundary.OnError$ OnError()

OnNext

public ActorGraphInterpreter.BatchingActorInputBoundary.OnNext$ OnNext()

OnSubscribe

public ActorGraphInterpreter.BatchingActorInputBoundary.OnSubscribe$ OnSubscribe()

cancel

public void cancel()

onComplete

public void onComplete()

onDownstreamFinish

public void onDownstreamFinish()

Description copied from interface: OutHandler

Called when the output port will no longer accept any new elements. After this callback no other callbacks will be called for this port.

Specified by:

onDownstreamFinish in interface OutHandler

onError

public void onError(java.lang.Throwable e)

onInternalError

public void onInternalError(java.lang.Throwable e)

onNext

public void onNext(java.lang.Object elem)

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. {@link GraphStageLogic.push()} is now allowed to be called on this port.

Specified by:

onPull in interface OutHandler

onSubscribe

public void onSubscribe(org.reactivestreams.Subscription subscription)

out

public Outlet<java.lang.Object> out()

Specified by:

out in class GraphInterpreter.UpstreamBoundaryStageLogic<java.lang.Object>

preStart

public void preStart()

Description copied from class: GraphStageLogic

Invoked before any external events are processed, at the startup of the operator.

Overrides:

preStart in class GraphStageLogic

setActor

public void setActor(ActorRef actor)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object