akka.actor

IO

object IO extends AnyRef

IO messages and iteratees.

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

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Hide All
  2. Show all
  1. IO
  2. AnyRef
  3. Any
Visibility
  1. Public
  2. All

Type Members

  1. case class Accept(socket: SocketHandle, server: ServerHandle) extends IOMessage with Product with Serializable

    Message to an IOManager to accept a new connection.

  2. case class Chunk(bytes: ByteString) extends Input with Product with Serializable

    Part of an Input stream that contains a chunk of bytes.

  3. case class Close(handle: Handle) extends IOMessage with Product with Serializable

    Message to an IOManager to close the Channel.

  4. case class Closed(handle: Handle, cause: Option[Exception]) extends IOMessage with Product with Serializable

    Message from an IOManager that the Channel has closed.

  5. case class Connect(socket: SocketHandle, address: SocketAddress) extends IOMessage with Product with Serializable

    Message to an IOManager to create a SocketChannel connected to the provided address.

  6. case class Connected(socket: SocketHandle, address: SocketAddress) extends IOMessage with Product with Serializable

    Message from an IOManager that the SocketChannel has successfully connected.

  7. final case class Cont[+A](f: (Input) ⇒ (Iteratee[A], Input), error: Option[Exception]) extends Iteratee[A] with Product with Serializable

    An Iteratee that still requires more input to calculate it's result.

  8. final class DivergentIterateeException extends Exception

  9. final case class Done[+A](result: A) extends Iteratee[A] with Product with Serializable

    An Iteratee representing a result, usually returned by the successful completion of an Iteratee.

  10. case class EOF(cause: Option[Exception]) extends Input with Product with Serializable

    Part of an Input stream that represents the end of the stream.

  11. sealed trait Handle extends AnyRef

    An immutable handle to a Java NIO Channel.

  12. sealed trait IOMessage extends AnyRef

    Messages used to communicate with an IOManager.

  13. sealed trait Input extends AnyRef

    Represents part of a stream of bytes that can be processed by an Iteratee.

  14. sealed abstract class Iteratee[+A] extends AnyRef

    A basic Iteratee implementation of Oleg's Iteratee (http://okmij.

  15. trait IterateeRef[A] extends AnyRef

    A mutable reference to an Iteratee designed for use within an Actor.

  16. final class IterateeRefAsync[A] extends IterateeRef[A]

    A mutable reference to an Iteratee.

  17. final class IterateeRefSync[A] extends IterateeRef[A]

    A mutable reference to an Iteratee.

  18. case class Listen(server: ServerHandle, address: SocketAddress) extends IOMessage with Product with Serializable

    Message to an IOManager to create a ServerSocketChannel listening on the provided address.

  19. case class Listening(server: ServerHandle, address: SocketAddress) extends IOMessage with Product with Serializable

    Message from an IOManager that the ServerSocketChannel is now listening for connections.

  20. case class NewClient(server: ServerHandle) extends IOMessage with Product with Serializable

    Message from an IOManager that a new connection has been made to the ServerSocketChannel and needs to be accepted.

  21. case class Read(handle: ReadHandle, bytes: ByteString) extends IOMessage with Product with Serializable

    Message from an IOManager that contains bytes read from the SocketChannel.

  22. sealed trait ReadHandle extends Handle with Product

    A Handle to a ReadableByteChannel.

  23. case class ServerHandle(owner: ActorRef, ioManager: ActorRef, uuid: UUID) extends Handle with Product with Serializable

    A Handle to a ServerSocketChannel.

  24. case class SocketHandle(owner: ActorRef, ioManager: ActorRef, uuid: UUID) extends ReadHandle with WriteHandle with Product with Serializable

    A Handle to a SocketChannel.

  25. case class Write(handle: WriteHandle, bytes: ByteString) extends IOMessage with Product with Serializable

    Message to an IOManager to write to the SocketChannel.

  26. sealed trait WriteHandle extends Handle with Product

    A Handle to a WritableByteChannel.

Value Members

  1. final def !=(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any
  3. final def ##(): Int

    Definition Classes
    AnyRef → Any
  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any
  6. object Chunk extends Serializable

  7. object Iteratee extends AnyRef

  8. object IterateeRef extends AnyRef

  9. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  10. def clone(): AnyRef

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  11. def drop(length: Int): Iteratee[Unit]

    An Iteratee that ignores the specified number of bytes.

  12. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  13. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  14. def finalize(): Unit

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  15. def fold[A, B, M[A] <: Traversable[A]](initial: B, in: M[A])(f: (B, A) ⇒ Iteratee[B]): Iteratee[B]

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

  16. final def getClass(): java.lang.Class[_]

    Definition Classes
    AnyRef → Any
  17. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  18. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  19. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  20. final def notify(): Unit

    Definition Classes
    AnyRef
  21. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  22. def peek(length: Int): Iteratee[ByteString]

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

  23. def repeat(iter: Iteratee[Unit]): Iteratee[Unit]

    An Iteratee that continually repeats an Iteratee.

    An Iteratee that continually repeats an Iteratee.

    TODO: Should terminate on EOF

  24. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  25. def take(length: Int): Iteratee[ByteString]

    An Iteratee that returns a ByteString of the requested length.

  26. val takeAll: Iteratee[ByteString]

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

  27. val takeAny: Iteratee[ByteString]

    An Iteratee that returns any input it receives

  28. def takeList[A](length: Int)(iter: Iteratee[A]): Iteratee[List[A]]

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

  29. def takeUntil(delimiter: ByteString, inclusive: Boolean = false): Iteratee[ByteString]

    An Iteratee that returns the ByteString prefix up until the supplied delimiter.

    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'.

  30. def takeWhile(p: (Byte) ⇒ Boolean): Iteratee[ByteString]

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

  31. final def throwErr(err: Exception): Iteratee[Nothing]

    An Iteratee that contains an Exception.

    An Iteratee that contains an Exception. The Exception can be handled with Iteratee.recover().

  32. def toString(): String

    Definition Classes
    AnyRef → Any
  33. def traverse[A, B, M[A] <: Traversable[A]](in: M[A])(f: (A) ⇒ Iteratee[B])(implicit cbf: CanBuildFrom[M[A], B, M[B]]): Iteratee[M[B]]

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

  34. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws()
  35. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws()
  36. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws()

Inherited from AnyRef

Inherited from Any