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.

Nested Class Summary

Nested classes/interfaces inherited from interface akka.actor.IO.IterateeRef

IO.IterateeRef.Map<K,V>, IO.IterateeRef.Map$

Constructor Summary

IO.IterateeRefSync(IO.Iteratee<A> initial)

Method Summary

void	apply(IO.Input input)
void	flatMap(scala.Function1<A,IO.Iteratee<A>> f)
void	map(scala.Function1<A,A> f)
scala.Tuple2<IO.Iteratee<A>,IO.Input>	value() Returns the current value of this IterateeRefSync

Methods inherited from class java.lang.Object

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

Constructor Detail

IO.IterateeRefSync

public IO.IterateeRefSync(IO.Iteratee<A> initial)

Method Detail

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