akka.stream.impl.fusing

Class IteratorInterpreter<I,O>

java.lang.Object

akka.stream.impl.fusing.IteratorInterpreter<I,O>

public class IteratorInterpreter<I,O>
extends java.lang.Object

INTERNAL API

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	IteratorInterpreter.IteratorDownstream<T>
static class	IteratorInterpreter.IteratorDownstream$
static class	IteratorInterpreter.IteratorUpstream<T>
static class	IteratorInterpreter.IteratorUpstream$

Constructor Summary

Constructors

Constructor and Description
IteratorInterpreter(scala.collection.Iterator<I> input, scala.collection.Seq<GraphStageWithMaterializedValue<FlowShape<?,?>,java.lang.Object>> stages)

Method Summary

Modifier and Type	Method and Description
scala.collection.Iterator<I>	input()
scala.collection.Iterator<O>	iterator()
scala.collection.Seq<GraphStageWithMaterializedValue<FlowShape<?,?>,java.lang.Object>>	stages()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

IteratorInterpreter

public IteratorInterpreter(scala.collection.Iterator<I> input,
                           scala.collection.Seq<GraphStageWithMaterializedValue<FlowShape<?,?>,java.lang.Object>> stages)

Method Detail

input

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

stages

public scala.collection.Seq<GraphStageWithMaterializedValue<FlowShape<?,?>,java.lang.Object>> stages()

iterator

public scala.collection.Iterator<O> iterator()