Unix Domain Socket - Always deregister interest in OP_READ after call…

…ing channel.read
akka · Jul 2, 2018 · 5932b0c · 5932b0c
1 parent 3b06c06
commit 5932b0c
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/...ocket/src/main/scala/akka/stream/alpakka/unixdomainsocket/scaladsl/UnixDomainSocket.scala b/...ocket/src/main/scala/akka/stream/alpakka/unixdomainsocket/scaladsl/UnixDomainSocket.scala
@@ -168,10 +168,13 @@ object UnixDomainSocket extends ExtensionId[UnixDomainSocket] with ExtensionIdPr
                       val pendingResult = queue.offer(ByteString(buffer))
                       pendingResult.onComplete(_ => sel.wakeup())
                       sendReceiveContext.receive = PendingReceiveAck(queue, buffer, pendingResult)
-                      key.interestOps(key.interestOps() & ~SelectionKey.OP_READ)
+
                     } else {
                       queue.complete()
                     }
+
+                    key.interestOps(key.interestOps() & ~SelectionKey.OP_READ)
+
                   case PendingReceiveAck(receiveQueue, receiveBuffer, pendingResult) if pendingResult.isCompleted =>
                     pendingResult.value.get match {
                       case Success(QueueOfferResult.Enqueued) =>