akka.stream.impl.fusing

Class IteratorInterpreter.IteratorDownstream<T>

java.lang.Object

akka.stream.stage.GraphStageLogic

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

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

All Implemented Interfaces:

InHandler, java.io.Serializable, scala.collection.GenTraversableOnce<T>, scala.collection.Iterator<T>, scala.collection.TraversableOnce<T>, scala.Equals, scala.Product

Enclosing class:

IteratorInterpreter<I,O>

public static final class IteratorInterpreter.IteratorDownstream<T>
extends GraphInterpreter.DownstreamBoundaryStageLogic<T>
implements scala.collection.Iterator<T>, InHandler, 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$

Nested classes/interfaces inherited from interface scala.collection.Iterator

scala.collection.Iterator.ConcatIterator<A>, scala.collection.Iterator.ConcatIteratorCell<A>, scala.collection.Iterator.GroupedIterator<B>, scala.collection.Iterator.SliceIterator<A>

Nested classes/interfaces inherited from interface scala.collection.TraversableOnce

scala.collection.TraversableOnce.BufferedCanBuildFrom<A,CC extends scala.collection.TraversableOnce<java.lang.Object>>, scala.collection.TraversableOnce.FlattenOps<A>, scala.collection.TraversableOnce.ForceImplicitAmbiguity, scala.collection.TraversableOnce.MonadOps<A>, scala.collection.TraversableOnce.OnceCanBuildFrom<A>

Constructor Summary

Constructors

Constructor and Description
IteratorDownstream()

Method Summary

Modifier and Type	Method and Description
boolean	hasNext()
Inlet<T>	in()
T	next()
void	onPush() Called when the input port has a new element available.
void	onUpstreamFailure(java.lang.Throwable cause) Called when the input port has failed.
void	onUpstreamFinish() Called when the input port is finished.
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.collection.Iterator

$init$, $plus$plus, apply, buffered, collect, contains, continually, copyToArray, corresponds, drop, dropWhile, duplicate, empty, exists, fill, filter, filterNot, find, flatMap, forall, foreach, from, from, grouped, hasDefiniteSize, indexOf, indexOf, indexWhere, indexWhere, isEmpty, isTraversableAgain, iterate, IteratorCanBuildFrom, length, map, padTo, partition, patch, range, range, sameElements, scanLeft, scanRight, seq, single, slice, sliceIterator, sliding, sliding$default$2, span, tabulate, take, takeWhile, toIterator, toStream, toTraversable, withFilter, zip, zipAll, zipWithIndex

Methods inherited from interface scala.collection.TraversableOnce

$colon$bslash, $div$colon, $init$, addString, addString, addString, aggregate, alternateImplicit, collectFirst, copyToArray, copyToArray, copyToBuffer, count, flattenTraversableOnce, fold, foldLeft, foldRight, max, maxBy, min, minBy, mkString, mkString, mkString, MonadOps, nonEmpty, OnceCanBuildFrom, product, reduce, reduceLeft, reduceLeftOption, reduceOption, reduceRight, reduceRightOption, reversed, size, sum, to, toArray, toBuffer, toIndexedSeq, toIterable, toList, toMap, toSeq, toSet, toVector

Methods inherited from interface scala.collection.GenTraversableOnce

$init$, sizeHintIfCheap

Methods inherited from interface scala.Product

$init$, productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

IteratorDownstream

public IteratorDownstream()

Method Detail

in

public Inlet<T> in()

Specified by:

in in class GraphInterpreter.DownstreamBoundaryStageLogic<T>

onPush

public void onPush()

Description copied from interface: InHandler

Called when the input port has a new element available. The actual element can be retrieved via the GraphStageLogic.grab() method.

Specified by:

onPush in interface InHandler

onUpstreamFinish

public void onUpstreamFinish()

Description copied from interface: InHandler

Called when the input port is finished. After this callback no other callbacks will be called for this port.

Specified by:

onUpstreamFinish in interface InHandler

onUpstreamFailure

public void onUpstreamFailure(java.lang.Throwable cause)

Description copied from interface: InHandler

Called when the input port has failed. After this callback no other callbacks will be called for this port.

Specified by:

onUpstreamFailure in interface InHandler

Parameters:

cause - (undocumented)

hasNext

public boolean hasNext()

Specified by:

hasNext in interface scala.collection.Iterator<T>

next

public T next()

Specified by:

next in interface scala.collection.Iterator<T>

toString

public java.lang.String toString()

Specified by:

toString in interface scala.collection.Iterator<T>

Overrides:

toString in class java.lang.Object