Message to an akka.actor.IOManager to accept a new connection with the given akka.actor.IO.SocketOptions.
akka.actor.IO.ServerSocketOption to set the maximum backlog of connections.
Part of an akka.actor.IO.Input stream that contains a chunk of bytes.
Message to an akka.actor.IOManager to close the Channel.
Message from an akka.actor.IOManager that the Channel has closed.
Message to an akka.actor.IOManager to create a SocketChannel connected to the provided address with the given akka.actor.IO.SocketOptions.
Message from an akka.actor.IOManager that the SocketChannel has successfully connected.
An Iteratee representing a result, usually returned by the successful completion of an Iteratee.
Part of an akka.actor.IO.Input stream that represents an error in the stream.
An akka.actor.IO.Iteratee that represents an erronous end state.
An immutable handle to a Java NIO Channel.
Messages used to communicate with an akka.actor.IOManager.
Represents part of a stream of bytes that can be processed by an akka.actor.IO.Iteratee.
A basic Iteratee implementation of Oleg's Iteratee (http://okmij.
A mutable reference to an Iteratee designed for use within an Actor.
A mutable reference to an akka.actor.IO.Iteratee.
A mutable reference to an akka.actor.IO.Iteratee.
akka.actor.IO.SocketOption to enable or disable SO_KEEPALIVE
Message to an akka.actor.IOManager to create a ServerSocketChannel listening on the provided address with the given akka.actor.IO.ServerSocketOptions.
Message from an akka.actor.IOManager that the ServerSocketChannel is now listening for connections.
Message from an akka.actor.IOManager that a new connection has been made to the ServerSocketChannel and needs to be accepted.
An akka.actor.IO.Iteratee that still requires more input to calculate it's result.
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.
akka.actor.IO.SocketOption to set performance preferences for this akka.actor.IO.SocketHandle.
Message from an akka.actor.IOManager that contains bytes read from the SocketChannel.
A akka.actor.IO.Handle to a ReadableByteChannel.
akka.actor.IO.SocketOption to set the SO_RCVBUF option for this akka.actor.IO.SocketHandle.
akka.actor.IO.SocketOption to enable or disable SO_REUSEADDR
akka.actor.IO.SocketOption to set the SO_SNDBUF option for this akka.actor.IO.SocketHandle.
A akka.actor.IO.Handle to a ServerSocketChannel.
Options to be set when setting up a akka.actor.IO.ServerHandle
akka.actor.IO.SocketOption to enable or disable SO_LINGER with the specified linger time in seconds.
akka.actor.IO.SocketOption to set SO_TIMEOUT to the specified timeout rounded down to the nearest millisecond.
A akka.actor.IO.Handle to a SocketChannel.
Options to be set when setting up a akka.actor.IO.SocketHandle
akka.actor.IO.SocketOption to enable or disable TCP_NODELAY (disable or enable Nagle's algorithm)
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.
Message to an akka.actor.IOManager to write to the SocketChannel.
A akka.actor.IO.Handle to a WritableByteChannel.
Part of an akka.actor.IO.Input stream that represents the end of the stream.
An Iteratee that ignores the specified number of bytes.
An Iteratee that folds over a Traversable by applying a function that returns an Iteratee.
An Iteratee that returns a akka.util.ByteString of the request length, but does not consume the Input.
An Iteratee that continually repeats an Iteratee.
An Iteratee that returns a ByteString of the requested length.
An Iteratee that returns the remaining ByteString until an EOF is given.
An Iteratee that returns any input it receives
An Iteratee that creates a list made up of the results of an Iteratee.
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'.
An Iteratee that will collect bytes as long as a predicate is true.
An Iteratee that applies an Iteratee to each element of a Traversable and finally returning a single Iteratee containing a Traversable of the results.
IO messages and iteratees.
This is still in an experimental state and is subject to change until it has received more real world testing.
(Since version 2.2) use the new implementation in package akka.io instead