diff --git a/akka-actor/src/main/scala/akka/io/TcpConnection.scala b/akka-actor/src/main/scala/akka/io/TcpConnection.scala index b5e46d99b6..fdc84967ad 100644 --- a/akka-actor/src/main/scala/akka/io/TcpConnection.scala +++ b/akka-actor/src/main/scala/akka/io/TcpConnection.scala @@ -197,7 +197,8 @@ private[io] abstract class TcpConnection(val tcp: TcpExt, val channel: SocketCha /** stopWith sets this state while waiting for the SelectionHandler to execute the `cancelAndClose` thunk */ def unregistering: Receive = { - case Unregistered => context.stop(self) // postStop will notify interested parties + case Unregistered => context.stop(self) // postStop will notify interested parties + case ChannelReadable | ChannelWritable | ChannelAcceptable | ChannelConnectable => // ignore, we are going away soon anyway } // AUXILIARIES and IMPLEMENTATION