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, channel, closedMessage, closeReason, closing, closingWithPendingWrite, completeConnect, connected, doCloseConnection, doNothing, doRead, doWrite, handleClose, handleError, handleWriteMessages, peerSentEOF, PendingBufferWrite, PendingWrite, PendingWriteFile, postRestart, postStop, pullMode, resumeReading, safeShutdownOutput, signDeathPact, stopWith, suspendReading, tcp, unsignDeathPact, waitingForRegistration, writePending
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, preRestart, preStart, self, sender, supervisorStrategy, unhandled
_log, 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