[FIXED] Possible delay in flushing data

Signed-off-by: Ivan Kozlovic <[email protected]>
nats-io · Feb 7, 2019 · bc8db76 · bc8db76
1 parent ce2df36
commit bc8db76
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
 }