public class TcpIncomingConnection extends TcpConnection
INTERNAL API
TcpConnection.AllRead$, TcpConnection.CloseInformation, TcpConnection.CloseInformation$, TcpConnection.ConnectionInfo, TcpConnection.ConnectionInfo$, TcpConnection.EmptyPendingWrite$, TcpConnection.EndOfStream$, TcpConnection.MoreDataWaiting$, TcpConnection.PendingBufferWrite, TcpConnection.PendingWrite, TcpConnection.PendingWriteFile, TcpConnection.ReadResult, TcpConnection.UpdatePendingWriteAndThen, TcpConnection.UpdatePendingWriteAndThen$, TcpConnection.WriteFileFailed, TcpConnection.WriteFileFailed$
Actor.emptyBehavior$, Actor.ignoringBehavior$
Constructor and Description |
---|
TcpIncomingConnection(TcpExt _tcp,
java.nio.channels.SocketChannel _channel,
ChannelRegistry registry,
ActorRef bindHandler,
scala.collection.immutable.Traversable<Inet.SocketOption> options,
boolean readThrottling) |
Modifier and Type | Method and Description |
---|---|
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receive()
This defines the initial actor behavior, it must return a partial function
with the actor logic.
|
abort, akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, akka$actor$ActorLogging$$_log_$eq, akka$actor$ActorLogging$$_log, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, channel, closedMessage, closeReason, closing, closingWithPendingWrite, completeConnect, connected, context, doCloseConnection, doNothing, doRead, doWrite, DroppingWriteBecauseQueueIsFullException, DroppingWriteBecauseWritingIsSuspendedException, handleClose, handleError, handleWriteMessages, log, peerSentEOF, PendingBufferWrite, PendingWrite, PendingWriteFile, postRestart, postStop, preRestart, preStart, pullMode, resumeReading, safeShutdownOutput, self, sender, signDeathPact, stopWith, supervisorStrategy, suspendReading, tcp, unhandled, unsignDeathPact, waitingForRegistration, writePending
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, preRestart, preStart, sender, supervisorStrategy, unhandled
log
public TcpIncomingConnection(TcpExt _tcp, java.nio.channels.SocketChannel _channel, ChannelRegistry registry, ActorRef bindHandler, scala.collection.immutable.Traversable<Inet.SocketOption> options, boolean readThrottling)
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
Actor
receive
in interface Actor
receive
in class TcpConnection