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/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
All Methods Instance Methods Concrete Methods 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
-
-
-
-
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 interfaceOutHandler
-
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 interfaceOutHandler
-
onSubscribe
public void onSubscribe(org.reactivestreams.Subscription subscription)
-
out
public Outlet<java.lang.Object> out()
- Specified by:
out
in classGraphInterpreter.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 classGraphStageLogic
-
setActor
public void setActor(ActorRef actor)
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-