public static final class IteratorInterpreter.IteratorUpstream<T> extends GraphInterpreter.UpstreamBoundaryStageLogic<T> implements OutHandler, scala.Product, scala.Serializable
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 |
---|
IteratorUpstream(scala.collection.Iterator<T> input) |
Modifier and Type | Method and Description |
---|---|
scala.collection.Iterator<T> |
input() |
void |
onDownstreamFinish()
Called when the output port will no longer accept any new elements.
|
void |
onPull()
Called when the output port has received a pull, and therefore ready to emit an element, i.e.
|
Outlet<T> |
out() |
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
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
public IteratorUpstream(scala.collection.Iterator<T> input)
public scala.collection.Iterator<T> input()
public Outlet<T> out()
out
in class GraphInterpreter.UpstreamBoundaryStageLogic<T>
public void onPull()
OutHandler
GraphStageLogic.push()
is now allowed to be called on this port.onPull
in interface OutHandler
public void onDownstreamFinish()
OutHandler
onDownstreamFinish
in interface OutHandler
public java.lang.String toString()
toString
in class java.lang.Object