akka.stream.impl.fusing

Class IteratorInterpreter.IteratorUpstream<T>

java.lang.Object

akka.stream.stage.GraphStageLogic

akka.stream.impl.fusing.GraphInterpreter.UpstreamBoundaryStageLogic<T>

akka.stream.impl.fusing.IteratorInterpreter.IteratorUpstream<T>

All Implemented Interfaces:

OutHandler, java.io.Serializable, scala.Equals, scala.Product

Enclosing class:

IteratorInterpreter<I,O>

public static final class IteratorInterpreter.IteratorUpstream<T>
extends GraphInterpreter.UpstreamBoundaryStageLogic<T>
implements OutHandler, scala.Product, scala.Serializable

See Also:

Serialized Form

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
IteratorUpstream(scala.collection.Iterator<T> input)

Method Summary

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()

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

Methods inherited from interface scala.Product

$init$, productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

IteratorUpstream

public IteratorUpstream(scala.collection.Iterator<T> input)

Method Detail

input

public scala.collection.Iterator<T> input()

out

public Outlet<T> out()

Specified by:

out in class GraphInterpreter.UpstreamBoundaryStageLogic<T>

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

Specified by:

onPull in interface OutHandler

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

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object