akka.actor
Class IO$

java.lang.Object
  akka.actor.IO$

public class IO$
extends java.lang.Object

IO messages and iteratees.

This is still in an experimental state and is subject to change until it has received more real world testing.

Field Summary

static IO$

MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

IO$()

Method Summary

IO.Iteratee<scala.runtime.BoxedUnit>	drop(int length) An Iteratee that ignores the specified number of bytes.
<A,B,M extends scala.collection.Traversable<java.lang.Object>> IO.Iteratee<B>	fold(B initial, M in, scala.Function2<B,A,IO.Iteratee<B>> f) An Iteratee that folds over a Traversable by applying a function that returns an Iteratee.
IO.Iteratee<ByteString>	peek(int length) An Iteratee that returns a ByteString of the request length, but does not consume the Input.
<T> IO.Iteratee<T>	repeat(IO.Iteratee<T> iter) An Iteratee that continually repeats an Iteratee.
IO.Iteratee<ByteString>	take(int length) An Iteratee that returns a ByteString of the requested length.
IO.Iteratee<ByteString>	takeAll() An Iteratee that returns the remaining ByteString until an EOF is given.
IO.Iteratee<ByteString>	takeAny() An Iteratee that returns any input it receives
<A> IO.Iteratee<scala.collection.immutable.List<A>>	takeList(int length, IO.Iteratee<A> iter) An Iteratee that creates a list made up of the results of an Iteratee.
IO.Iteratee<ByteString>	takeUntil(ByteString delimiter, boolean inclusive) An Iteratee that returns the ByteString prefix up until the supplied delimiter.
IO.Iteratee<ByteString>	takeWhile(scala.Function1<java.lang.Object,java.lang.Object> p) An Iteratee that will collect bytes as long as a predicate is true.
<A,B,M extends scala.collection.Traversable<java.lang.Object>> IO.Iteratee<M>	traverse(M in, scala.Function1<A,IO.Iteratee<B>> f, scala.collection.generic.CanBuildFrom<M,B,M> cbf) An Iteratee that applies an Iteratee to each element of a Traversable and finally returning a single Iteratee containing a Traversable of the results.

Methods inherited from class java.lang.Object

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

Field Detail

MODULE$

public static final IO$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

IO$

public IO$()

Method Detail

takeUntil

public IO.Iteratee<ByteString> takeUntil(ByteString delimiter,
                                         boolean inclusive)

An Iteratee that returns the ByteString prefix up until the supplied delimiter. The delimiter is dropped by default, but it can be returned with the result by setting 'inclusive' to be 'true'.

takeWhile

public IO.Iteratee<ByteString> takeWhile(scala.Function1<java.lang.Object,java.lang.Object> p)

An Iteratee that will collect bytes as long as a predicate is true.

take

public IO.Iteratee<ByteString> take(int length)

An Iteratee that returns a ByteString of the requested length.

drop

public IO.Iteratee<scala.runtime.BoxedUnit> drop(int length)

An Iteratee that ignores the specified number of bytes.

takeAll

public IO.Iteratee<ByteString> takeAll()

An Iteratee that returns the remaining ByteString until an EOF is given.

takeAny

public IO.Iteratee<ByteString> takeAny()

An Iteratee that returns any input it receives

takeList

public <A> IO.Iteratee<scala.collection.immutable.List<A>> takeList(int length,
                                                                    IO.Iteratee<A> iter)

An Iteratee that creates a list made up of the results of an Iteratee.

peek

public IO.Iteratee<ByteString> peek(int length)

An Iteratee that returns a ByteString of the request length, but does not consume the Input.

repeat

public <T> IO.Iteratee<T> repeat(IO.Iteratee<T> iter)

An Iteratee that continually repeats an Iteratee.

traverse

public <A,B,M extends scala.collection.Traversable<java.lang.Object>> IO.Iteratee<M> traverse(M in,
                                                                                              scala.Function1<A,IO.Iteratee<B>> f,
                                                                                              scala.collection.generic.CanBuildFrom<M,B,M> cbf)

An Iteratee that applies an Iteratee to each element of a Traversable and finally returning a single Iteratee containing a Traversable of the results.

fold

public <A,B,M extends scala.collection.Traversable<java.lang.Object>> IO.Iteratee<B> fold(B initial,
                                                                                          M in,
                                                                                          scala.Function2<B,A,IO.Iteratee<B>> f)

An Iteratee that folds over a Traversable by applying a function that returns an Iteratee.