akka.actor

IO

object IO

IO messages and iteratees.

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

Annotations
@deprecated
Deprecated

(Since version 2.2) use the new implementation in package akka.io instead

Linear Supertypes
AnyRef, Any
Content Hierarchy Learn more about scaladoc diagrams
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. IO
  2. AnyRef
  3. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Type Members

  1. case class Accept(socket: SocketHandle, server: ServerHandle, options: Seq[SocketOption] = immutable.this.Nil) extends IOMessage with Product with Serializable

    Message to an akka.actor.IOManager to accept a new connection with the given akka.actor.IO.SocketOptions.

  2. case class Backlog(numberOfConnections: Int) extends ServerSocketOption with Product with Serializable

    akka.actor.IO.ServerSocketOption to set the maximum backlog of connections.

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

    Part of an akka.actor.IO.Input stream that contains a chunk of bytes.

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

    Message to an akka.actor.IOManager to close the Channel.

  5. case class Closed(handle: Handle, cause: Input) extends IOMessage with Product with Serializable

    Message from an akka.actor.IOManager that the Channel has closed.

  6. case class Connect(socket: SocketHandle, address: SocketAddress, options: Seq[SocketOption] = immutable.this.Nil) extends IOMessage with Product with Serializable

    Message to an akka.actor.IOManager to create a SocketChannel connected to the provided address with the given akka.actor.IO.SocketOptions.

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

    Message from an akka.actor.IOManager that the SocketChannel has successfully connected.

  8. final class DivergentIterateeException extends IllegalStateException

  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 Error(cause: Throwable) extends Input with Product with Serializable

    Part of an akka.actor.IO.Input stream that represents an error in the stream.

  11. final case class Failure(cause: Throwable) extends Iteratee[Nothing] with Product with Serializable

    An akka.actor.IO.Iteratee that represents an erronous end state.

  12. sealed trait Handle extends AnyRef

    An immutable handle to a Java NIO Channel.

  13. sealed trait IOMessage extends AnyRef

    Messages used to communicate with an akka.actor.IOManager.

  14. sealed trait Input extends AnyRef

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

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

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

  16. trait IterateeRef[A] extends AnyRef

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

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

    A mutable reference to an akka.actor.IO.Iteratee.

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

    A mutable reference to an akka.actor.IO.Iteratee.

  19. case class KeepAlive(on: Boolean) extends SocketOption with Product with Serializable

    akka.actor.IO.SocketOption to enable or disable SO_KEEPALIVE

  20. case class Listen(server: ServerHandle, address: SocketAddress, options: Seq[ServerSocketOption] = immutable.this.Nil) extends IOMessage with Product with Serializable

    Message to an akka.actor.IOManager to create a ServerSocketChannel listening on the provided address with the given akka.actor.IO.ServerSocketOptions.

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

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

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

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

  23. final case class Next[+A](f: (Input) ⇒ (Iteratee[A], Input)) extends Iteratee[A] with Product with Serializable

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

  24. case class OOBInline(on: Boolean) extends SocketOption with Product with Serializable

    akka.actor.IO.SocketOption to enable or disable OOBINLINE (receipt of TCP urgent data) By default, this option is disabled and TCP urgent data received on a akka.actor.IO.SocketHandle is silently discarded.

  25. case class PerformancePreferences(connectionTime: Int, latency: Int, bandwidth: Int) extends SocketOption with ServerSocketOption with Product with Serializable

    akka.actor.IO.SocketOption to set performance preferences for this akka.actor.IO.SocketHandle.

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

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

  27. sealed trait ReadHandle extends Handle with Product

    A akka.actor.IO.Handle to a ReadableByteChannel.

  28. case class ReceiveBufferSize(size: Int) extends SocketOption with ServerSocketOption with Product with Serializable

    akka.actor.IO.SocketOption to set the SO_RCVBUF option for this akka.actor.IO.SocketHandle.

  29. case class ReuseAddress(on: Boolean) extends SocketOption with ServerSocketOption with Product with Serializable

    akka.actor.IO.SocketOption to enable or disable SO_REUSEADDR

  30. case class SendBufferSize(size: Int) extends SocketOption with Product with Serializable

    akka.actor.IO.SocketOption to set the SO_SNDBUF option for this akka.actor.IO.SocketHandle.

  31. case class ServerHandle(owner: ActorRef, ioManager: ActorRef, uuid: UUID = java.util.UUID.randomUUID()) extends Handle with Product with Serializable

    A akka.actor.IO.Handle to a ServerSocketChannel.

  32. sealed trait ServerSocketOption extends AnyRef

    Options to be set when setting up a akka.actor.IO.ServerHandle

  33. case class SoLinger(linger: Option[Int]) extends SocketOption with Product with Serializable

    akka.actor.IO.SocketOption to enable or disable SO_LINGER with the specified linger time in seconds.

  34. case class SoTimeout(timeout: Duration) extends SocketOption with Product with Serializable

    akka.actor.IO.SocketOption to set SO_TIMEOUT to the specified timeout rounded down to the nearest millisecond.

  35. case class SocketHandle(owner: ActorRef, ioManager: ActorRef, uuid: UUID = java.util.UUID.randomUUID()) extends ReadHandle with WriteHandle with Product with Serializable

    A akka.actor.IO.Handle to a SocketChannel.

  36. sealed trait SocketOption extends AnyRef

    Options to be set when setting up a akka.actor.IO.SocketHandle

  37. case class TcpNoDelay(on: Boolean) extends SocketOption with Product with Serializable

    akka.actor.IO.SocketOption to enable or disable TCP_NODELAY (disable or enable Nagle's algorithm)

  38. case class TrafficClass(tc: Int) extends SocketOption with Product with Serializable

    akka.actor.IO.SocketOption to set the traffic class or type-of-service octet in the IP header for packets sent from this akka.actor.IO.SocketHandle.

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

    Message to an akka.actor.IOManager to write to the SocketChannel.

  40. sealed trait WriteHandle extends Handle with Product

    A akka.actor.IO.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 EOF extends Input with Product with Serializable

    Part of an akka.actor.IO.Input stream that represents the end of the stream.

  8. object Iteratee

  9. object IterateeRef

  10. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  11. def clone(): AnyRef

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

    An Iteratee that ignores the specified number of bytes.

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

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

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

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  16. 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.

  17. final def getClass(): Class[_]

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

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

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

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

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

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

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

  24. def repeat[T](iter: Iteratee[T]): Iteratee[T]

    An Iteratee that continually repeats an Iteratee.

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

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

    An Iteratee that returns a ByteString of the requested length.

  27. val takeAll: Iteratee[ByteString]

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

  28. val takeAny: Iteratee[ByteString]

    An Iteratee that returns any input it receives

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

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

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

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

  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

Ungrouped