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

Enclosing class:

ActorGraphInterpreter

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

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
BatchingActorInputBoundary(int size, int id)

Method Summary

Modifier and Type	Method and Description
void	cancel()
void	onComplete()
void	onError(java.lang.Throwable e)
void	onInternalError(java.lang.Throwable e)
void	onNext(java.lang.Object elem)
void	onSubscribe(org.reactivestreams.Subscription subscription)
Outlet<java.lang.Object>	out()
java.lang.String	toString()

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, postStop, 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, wait, wait, wait

Constructor Detail

BatchingActorInputBoundary

public BatchingActorInputBoundary(int size,
                                  int id)

Method Detail

out

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

Specified by:

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

cancel

public void cancel()

onNext

public void onNext(java.lang.Object elem)

onError

public void onError(java.lang.Throwable e)

onInternalError

public void onInternalError(java.lang.Throwable e)

onComplete

public void onComplete()

onSubscribe

public void onSubscribe(org.reactivestreams.Subscription subscription)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object