public static class ActorGraphInterpreter.ActorOutputBoundary extends GraphInterpreter.DownstreamBoundaryStageLogic<java.lang.Object>
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 and Description |
---|
ActorOutputBoundary(ActorRef actor,
GraphInterpreterShell shell,
int id) |
Modifier and Type | Method and Description |
---|---|
void |
cancel() |
void |
exposedPublisher(ActorPublisher<java.lang.Object> publisher) |
void |
fail(java.lang.Throwable e) |
Inlet<java.lang.Object> |
in() |
void |
requestMore(long elements) |
void |
subscribePending() |
java.lang.String |
toString() |
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, postStop, preStart, pull, push, read, read, readN, readN, setHandler, setHandler, setHandlers, setKeepGoing, stageActor, stageId, subFusingMaterializer, totallyIgnorantInput, tryPull
public ActorOutputBoundary(ActorRef actor, GraphInterpreterShell shell, int id)
public Inlet<java.lang.Object> in()
in
in class GraphInterpreter.DownstreamBoundaryStageLogic<java.lang.Object>
public void fail(java.lang.Throwable e)
public void subscribePending()
public void exposedPublisher(ActorPublisher<java.lang.Object> publisher)
public void requestMore(long elements)
public void cancel()
public java.lang.String toString()
toString
in class java.lang.Object