Package akka.io

Interface Summary
BufferPool  
ChannelRegistration Implementations of this interface are sent as actor messages back to a channel actor as a result of it having called register on the ChannelRegistry.
ChannelRegistry Interface behind which we hide our selector management logic from the connection actors
Inet.SocketOption SocketOption is a package of data (from the user) and associated behavior (how to apply that to a socket).
Inet.SoForwarders  
Inet.SoJavaFactories  
IO.Extension  
SelectionHandler.HasFailureMessage  
Tcp.CloseCommand Common interface for all commands which aim to close down an open connection.
Tcp.Command This is the common trait for all commands understood by TCP actors.
Tcp.ConnectionClosed This is the common interface for all events which indicate that a connection has been closed or half-closed.
Tcp.Event Common interface for all events generated by the TCP layer actors.
Tcp.Message The common interface for Tcp.WriteCommand and Tcp.Event.
Tcp.Unbound The sender of an Unbind command will receive confirmation through this message once the listening socket has been closed.
Tcp.WritingResumed When useResumeWriting is in effect as indicated in the Tcp.Register message, the ResumeWriting command will be acknowledged by this message type, upon which it is safe to send at least one write.
TcpConnection.ReadResult  
Udp.Command The common type of all commands supported by the UDP implementation.
Udp.Event The common type of all events emitted by the UDP implementation.
Udp.Message The common interface for Udp.Command and Udp.Event.
Udp.SimpleSenderReady The “simple sender” sends this message type in response to a Udp.SimpleSender query.
Udp.Unbound This message is sent by the listener actor in response to an Unbind command after the socket has been closed.
UdpConnected.Command The common type of all commands supported by the UDP implementation.
UdpConnected.Connected This message is sent by the connection actor to the actor which sent the UdpConnected.Connect message when the UDP socket has been bound to the local and remote addresses given.
UdpConnected.Disconnected This message is sent by the connection actor to the actor which sent the Disconnect message when the UDP socket has been closed.
UdpConnected.Event The common type of all events emitted by the UDP implementation.
UdpConnected.Message The common interface for UdpConnected.Command and UdpConnected.Event.
WithUdpSend INTERNAL API
 

Class Summary
DirectByteBufferPool INTERNAL API
Inet  
Inet.SO$  
Inet$  
IO Entry point to Akka’s IO layer.
IO$ Entry point to Akka’s IO layer.
SelectionHandler  
SelectionHandler.ChannelAcceptable$  
SelectionHandler.ChannelConnectable$  
SelectionHandler.ChannelReadable$  
SelectionHandler.ChannelWritable$  
SelectionHandler.Retry  
SelectionHandler.Retry$  
SelectionHandler.SelectorBasedManager  
SelectionHandler.WorkerForCommand  
SelectionHandler.WorkerForCommand$  
SelectionHandler$  
SelectionHandlerSettings  
Tcp TCP Extension for Akka’s IO layer.
Tcp.Abort$ An abort operation will not flush pending writes and will issue a TCP ABORT command to the O/S kernel which should result in a TCP_RST packet being sent to the peer.
Tcp.Aborted$ The connection has been aborted in response to an Abort command.
Tcp.Bind The Bind message is send to the TCP manager actor, which is obtained via TcpExt.manager() in order to bind to a listening socket.
Tcp.Bind$  
Tcp.Bound The sender of a Tcp.Bind command will—in case of success—receive confirmation in this form.
Tcp.Bound$  
Tcp.Close$ A normal close operation will first flush pending writes and then close the socket.
Tcp.Closed$ The connection has been closed normally in response to a Close command.
Tcp.CommandFailed Whenever a command cannot be completed, the queried actor will reply with this message, wrapping the original command which failed.
Tcp.CommandFailed$  
Tcp.CompoundWrite A write command which aggregates two other write commands.
Tcp.CompoundWrite$  
Tcp.ConfirmedClose$ A confirmed close operation will flush pending writes and half-close the connection, waiting for the peer to close the other half.
Tcp.ConfirmedClosed$ The connection has been half-closed by us and then half-close by the peer in response to a ConfirmedClose command.
Tcp.Connect The Connect message is sent to the TCP manager actor, which is obtained via TcpExt.manager().
Tcp.Connect$  
Tcp.Connected The connection actor sends this message either to the sender of a Tcp.Connect command (for outbound) or to the handler for incoming connections designated in the Tcp.Bind message.
Tcp.Connected$  
Tcp.ErrorClosed The connection has been closed due to an IO error.
Tcp.ErrorClosed$  
Tcp.NoAck Each Tcp.WriteCommand can optionally request a positive acknowledgment to be sent to the commanding actor.
Tcp.NoAck$ Default Tcp.NoAck instance which is used when no acknowledgment information is explicitly provided.
Tcp.PeerClosed$ The peer has closed its writing half of the connection.
Tcp.Received Whenever data are read from a socket they will be transferred within this class to the handler actor which was designated in the Tcp.Register message.
Tcp.Received$  
Tcp.Register This message must be sent to a TCP connection actor after receiving the Tcp.Connected message.
Tcp.Register$  
Tcp.ResumeAccepting This message enables the accepting of the next connection if read throttling is enabled for connection actors.
Tcp.ResumeAccepting$  
Tcp.ResumeReading$ This command needs to be sent to the connection actor after a SuspendReading command in order to resume reading from the socket.
Tcp.ResumeWriting$ When useResumeWriting is in effect as was indicated in the Tcp.Register message then this command needs to be sent to the connection actor in order to re-enable writing after a Tcp.CommandFailed event.
Tcp.SimpleWriteCommand Common supertype of Tcp.Write and Tcp.WriteFile.
Tcp.SO$ Scala API: this object contains all applicable socket options for TCP.
Tcp.SuspendReading$ Sending this command to the connection actor will disable reading from the TCP socket.
Tcp.Unbind$ In order to close down a listening socket, send this message to that socket’s actor (that is the actor which previously had sent the Tcp.Bound message).
Tcp.Unbound$  
Tcp.Write Write data to the TCP connection.
Tcp.Write$  
Tcp.WriteCommand Common interface for all write commands, currently Tcp.Write, Tcp.WriteFile and Tcp.CompoundWrite.
Tcp.WriteCommand$  
Tcp.WriteFile Write count bytes starting at position from file at filePath to the connection.
Tcp.WriteFile$  
Tcp.WritingResumed$  
Tcp$ TCP Extension for Akka’s IO layer.
TcpConnection Base class for TcpIncomingConnection and TcpOutgoingConnection.
TcpConnection.AllRead$  
TcpConnection.CloseInformation Used to transport information to the postStop method to notify interested party about a connection close.
TcpConnection.CloseInformation$  
TcpConnection.ConnectionInfo Groups required connection-related data that are only available once the connection has been fully established.
TcpConnection.ConnectionInfo$  
TcpConnection.EmptyPendingWrite$  
TcpConnection.EndOfStream$  
TcpConnection.MoreDataWaiting$  
TcpConnection.PendingWrite  
TcpConnection.UpdatePendingWriteAndThen  
TcpConnection.UpdatePendingWriteAndThen$  
TcpConnection.WriteFileFailed  
TcpConnection.WriteFileFailed$  
TcpConnection$ INTERNAL API
TcpExt  
TcpIncomingConnection An actor handling the connection state machine for an incoming, already connected SocketChannel.
TcpListener INTERNAL API
TcpListener.FailedRegisterIncoming  
TcpListener.FailedRegisterIncoming$  
TcpListener.RegisterIncoming  
TcpListener.RegisterIncoming$  
TcpListener$ INTERNAL API
TcpManager INTERNAL API
TcpMessage  
TcpMessage$  
TcpOutgoingConnection An actor handling the connection state machine for an outgoing connection to be established.
TcpSO Java API for accessing socket options.
TcpSO$ Java API for accessing socket options.
Udp UDP Extension for Akka’s IO layer.
Udp.Bind Send this message to the UdpExt.manager() in order to bind to the given local port (or an automatically assigned one if the port number is zero).
Udp.Bind$  
Udp.Bound This message is sent by the listener actor in response to a Udp.Bind command.
Udp.Bound$  
Udp.CommandFailed When a command fails it will be replied to with this message type, wrapping the failing command object.
Udp.CommandFailed$  
Udp.NoAck Each Udp.Send can optionally request a positive acknowledgment to be sent to the commanding actor.
Udp.NoAck$ Default Udp.NoAck instance which is used when no acknowledgment information is explicitly provided.
Udp.Received When a listener actor receives a datagram from its socket it will send it to the handler designated in the Udp.Bind message using this message type.
Udp.Received$  
Udp.ResumeReading$ This message must be sent to the listener actor to re-enable reading from the socket after a SuspendReading command.
Udp.Send This message is understood by the “simple sender” which can be obtained by sending the Udp.SimpleSender query to the UdpExt.manager() as well as by the listener actors which are created in response to Udp.Bind.
Udp.Send$  
Udp.SimpleSender Retrieve a reference to a “simple sender” actor of the UDP extension.
Udp.SimpleSender$  
Udp.SimpleSenderReady$  
Udp.SO$ Scala API: This object provides access to all socket options applicable to UDP sockets.
Udp.SuspendReading$ Send this message to a listener actor (which sent a Udp.Bound message) to have it stop reading datagrams from the network.
Udp.UdpSettings  
Udp.Unbind$ Send this message to the listener actor that previously sent a Udp.Bound message in order to close the listening socket.
Udp.Unbound$  
Udp$ UDP Extension for Akka’s IO layer.
UdpConnected UDP Extension for Akka’s IO layer.
UdpConnected.CommandFailed When a command fails it will be replied to with this message type, wrapping the failing command object.
UdpConnected.CommandFailed$  
UdpConnected.Connect Send this message to the UdpExt.manager() in order to bind to a local port (optionally with the chosen localAddress) and create a UDP socket which is restricted to sending to and receiving from the given remoteAddress.
UdpConnected.Connect$  
UdpConnected.Connected$  
UdpConnected.Disconnect$ Send this message to a connection actor (which had previously sent the UdpConnected.Connected message) in order to close the socket.
UdpConnected.Disconnected$  
UdpConnected.NoAck Each UdpConnected.Send can optionally request a positive acknowledgment to be sent to the commanding actor.
UdpConnected.NoAck$ Default UdpConnected.NoAck instance which is used when no acknowledgment information is explicitly provided.
UdpConnected.Received When a connection actor receives a datagram from its socket it will send it to the handler designated in the Udp.Bind message using this message type.
UdpConnected.Received$  
UdpConnected.ResumeReading$ This message must be sent to the listener actor to re-enable reading from the socket after a SuspendReading command.
UdpConnected.Send This message is understood by the connection actors to send data to their designated destination.
UdpConnected.Send$  
UdpConnected.SuspendReading$ Send this message to a listener actor (which sent a Udp.Bound message) to have it stop reading datagrams from the network.
UdpConnected$ UDP Extension for Akka’s IO layer.
UdpConnectedExt  
UdpConnectedManager INTERNAL API
UdpConnectedMessage Java API: factory methods for the message types used when communicating with the UdpConnected service.
UdpConnectedMessage$ Java API: factory methods for the message types used when communicating with the UdpConnected service.
UdpConnection INTERNAL API
UdpExt  
UdpListener INTERNAL API
UdpManager INTERNAL API
UdpMessage Java API: factory methods for the message types used when communicating with the Udp service.
UdpMessage$ Java API: factory methods for the message types used when communicating with the Udp service.
UdpSender INTERNAL API
UdpSO  
UdpSO$