Package org.apache.pekko.io
package org.apache.pekko.io
-
ClassDescriptionImplementations of this interface are sent as actor messages back to a channel actor as a result of it having called
registeron theChannelRegistry.Interface behind which we hide our selector management logic from the connection actorsINTERNAL APINot for user extension.Where as it is possible to plug in alternative DNS implementations it is not recommended.Java API: AbstractSocketOption is a package of data (from the user) and associated behavior (how to apply that to a channel).Java APIDatagramChannel creation behavior.SocketOption is a package of data (from the user) and associated behavior (how to apply that to a channel).INTERNAL APIINTERNAL APIEntry point to Akka’s IO layer.Entry point to Akka’s IO layer.INTERNAL APIINTERNAL APITCP Extension for Akka’s IO layer.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.The connection has been aborted in response to anAbortcommand.The Bind message is send to the TCP manager actor, which is obtained viaTcpExt.manager()in order to bind to a listening socket.The sender of aTcp.Bindcommand will—in case of success—receive confirmation in this form.A normal close operation will first flush pending writes and then close the socket.Common interface for all commands which aim to close down an open connection.The connection has been closed normally in response to aClosecommand.This is the common trait for all commands understood by TCP actors.Whenever a command cannot be completed, the queried actor will reply with this message, wrapping the original command which failed.A write command which aggregates two other write commands.A confirmed close operation will flush pending writes and half-close the connection, waiting for the peer to close the other half.The connection has been half-closed by us and then half-close by the peer in response to aConfirmedClosecommand.The Connect message is sent to the TCP manager actor, which is obtained viaTcpExt.manager().The connection actor sends this message either to the sender of aTcp.Connectcommand (for outbound) or to the handler for incoming connections designated in theTcp.Bindmessage.This is the common interface for all events which indicate that a connection has been closed or half-closed.The connection has been closed due to an IO error.Common interface for all events generated by the TCP layer actors.The common interface forTcp.CommandandTcp.Event.EachTcp.WriteCommandcan optionally request a positive acknowledgment to be sent to the commanding actor.DefaultTcp.NoAckinstance which is used when no acknowledgment information is explicitly provided.The peer has closed its writing half of the connection.Whenever data are read from a socket they will be transferred within this class to the handler actor which was designated in theTcp.Registermessage.This message must be sent to a TCP connection actor after receiving theTcp.Connectedmessage.This message enables the accepting of the next connection if read throttling is enabled for connection actors.This command needs to be sent to the connection actor after aSuspendReadingcommand in order to resume reading from the socket.WhenuseResumeWritingis in effect as was indicated in theTcp.Registermessage then this command needs to be sent to the connection actor in order to re-enable writing after aTcp.CommandFailedevent.Common supertype ofTcp.WriteandWriteFile.Scala API: this object contains all applicable socket options for TCP.Sending this command to the connection actor will disable reading from the TCP socket.In order to close down a listening socket, send this message to that socket’s actor (that is the actor which previously had sent theTcp.Boundmessage).The sender of anUnbindcommand will receive confirmation through this message once the listening socket has been closed.Write data to the TCP connection.Common interface for all write commands.Writecountbytes starting atpositionfrom file atfilePathto the connection.WhenuseResumeWritingis in effect as indicated in theTcp.Registermessage, theResumeWritingcommand will be acknowledged by this message type, upon which it is safe to send at least one write.TCP Extension for Akka’s IO layer.INTERNAL APIINTERNAL APIJava API for accessing socket options.Java API for accessing socket options.UDP Extension for Akka’s IO layer.Send this message to theUdpExt.manager()in order to bind to the given local port (or an automatically assigned one if the port number is zero).This message is sent by the listener actor in response to aUdp.Bindcommand.The common type of all commands supported by the UDP implementation.When a command fails it will be replied to with this message type, wrapping the failing command object.The common type of all events emitted by the UDP implementation.The common interface forUdp.CommandandUdp.Event.EachUdp.Sendcan optionally request a positive acknowledgment to be sent to the commanding actor.DefaultUdp.NoAckinstance which is used when no acknowledgment information is explicitly provided.When a listener actor receives a datagram from its socket it will send it to the handler designated in theUdp.Bindmessage using this message type.This message must be sent to the listener actor to re-enable reading from the socket after aSuspendReadingcommand.This message is understood by the “simple sender” which can be obtained by sending theUdp.SimpleSenderquery to theUdpExt.manager()as well as by the listener actors which are created in response toUdp.Bind.Retrieve a reference to a “simple sender” actor of the UDP extension.The “simple sender” sends this message type in response to aUdp.SimpleSenderquery.Scala API: This object provides access to all socket options applicable to UDP sockets.Send this message to a listener actor (which sent aUdp.Boundmessage) to have it stop reading datagrams from the network.Send this message to the listener actor that previously sent aUdp.Boundmessage in order to close the listening socket.This message is sent by the listener actor in response to anUnbindcommand after the socket has been closed.UDP Extension for Akka’s IO layer.UDP Extension for Akka’s IO layer.The common type of all commands supported by the UDP implementation.When a command fails it will be replied to with this message type, wrapping the failing command object.Send this message to theUdpExt.manager()in order to bind to a local port (optionally with the chosenlocalAddress) and create a UDP socket which is restricted to sending to and receiving from the givenremoteAddress.This message is sent by the connection actor to the actor which sent theUdpConnected.Connectmessage when the UDP socket has been bound to the local and remote addresses given.Send this message to a connection actor (which had previously sent theUdpConnected.Connectedmessage) in order to close the socket.This message is sent by the connection actor to the actor which sent theDisconnectmessage when the UDP socket has been closed.The common type of all events emitted by the UDP implementation.The common interface forUdpConnected.CommandandUdpConnected.Event.EachUdpConnected.Sendcan optionally request a positive acknowledgment to be sent to the commanding actor.DefaultUdpConnected.NoAckinstance which is used when no acknowledgment information is explicitly provided.When a connection actor receives a datagram from its socket it will send it to the handler designated in theUdp.Bindmessage using this message type.This message must be sent to the listener actor to re-enable reading from the socket after aSuspendReadingcommand.This message is understood by the connection actors to send data to their designated destination.Send this message to a listener actor (which sent aUdp.Boundmessage) to have it stop reading datagrams from the network.UDP Extension for Akka’s IO layer.Java API: factory methods for the message types used when communicating with the UdpConnected service.Java API: factory methods for the message types used when communicating with the UdpConnected service.Java API: factory methods for the message types used when communicating with the Udp service.Java API: factory methods for the message types used when communicating with the Udp service.Internal API: An unsynchronized byte array input stream.INTERNAL API