SAEA already in use error fix (akkadotnet#4301)

Aaronontheweb · Mar 6, 2020 · c726f11 · c726f11
1 parent 717fb24
commit c726f11
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/src/core/Akka/IO/TcpConnection.cs b/src/core/Akka/IO/TcpConnection.cs
@@ -314,7 +314,12 @@ private Receive HandleWriteMessages(ConnectionInfo info)
                         AcknowledgeSent();
 
                         // If there is something to send - send it
-                        DoWrite(info, GetAllowedPendingWrite());
+                        var pendingWrite = GetAllowedPendingWrite();
+                        if (pendingWrite.HasValue)
+                        {
+                            SetStatus(ConnectionStatus.Sending);
+                            DoWrite(info, pendingWrite);
+                        }
 
                         // If message is fully sent, notify sender who sent ResumeWriting command
                         if (!IsWritePending && _interestedInResume != null)