Merge pull request #901 from nats-io/fix_writeloop_signal_for_1_4_0

[FIXED] Possible delay in flushing data
nats-io · Feb 7, 2019 · 8e88372 · 8e88372
2 parents ce2df36 + bc8db76
commit 8e88372
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/server/client.go b/server/client.go
@@ -688,6 +688,11 @@ func (c *client) flushOutbound() bool {
 		}
 	}
 
+	// Signal again if there is still data to send
+	if c.out.pb > 0 {
+		c.out.sg.Signal()
+	}
+
 	return true
 }