akka.actor
Class IO.IterateeRefSync<A>
java.lang.Object
akka.actor.IO.IterateeRefSync<A>
- All Implemented Interfaces:
- IO.IterateeRef<A>
- Enclosing class:
- IO
public static final class IO.IterateeRefSync<A>
- extends java.lang.Object
- implements IO.IterateeRef<A>
A mutable reference to an IO.Iteratee
. Not thread safe.
Designed for use within an Actor
.
Includes mutable implementations of flatMap, map, and apply which
update the internal reference and return Unit.
IO.Input
remaining after processing the Iteratee will
be stored and processed later when 'flatMap' is used next.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
IO.IterateeRefSync
public IO.IterateeRefSync(IO.Iteratee<A> initial)
flatMap
public void flatMap(scala.Function1<A,IO.Iteratee<A>> f)
- Specified by:
flatMap
in interface IO.IterateeRef<A>
map
public void map(scala.Function1<A,A> f)
- Specified by:
map
in interface IO.IterateeRef<A>
apply
public void apply(IO.Input input)
- Specified by:
apply
in interface IO.IterateeRef<A>
value
public scala.Tuple2<IO.Iteratee<A>,IO.Input> value()
- Returns the current value of this IterateeRefSync