From eafe89237111fbec88fa05e136826211176382c0 Mon Sep 17 00:00:00 2001
From: Victor Elias <victorgelias@gmail.com>
Date: Tue, 13 Jul 2021 13:21:18 -0300
Subject: [PATCH] Make sure we enable flow for new connections

---
 publish.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/publish.go b/publish.go
index f189fab..ee7cce3 100644
--- a/publish.go
+++ b/publish.go
@@ -230,6 +230,10 @@ func (publisher *Publisher) startNotifyHandlers() {
 }
 
 func (publisher *Publisher) startNotifyFlowHandler(notifyFlowChan chan bool) {
+	publisher.disablePublishDueToFlowMux.Lock()
+	publisher.disablePublishDueToFlow = false
+	publisher.disablePublishDueToFlowMux.Unlock()
+
 	// Listeners for active=true flow control.  When true is sent to a listener,
 	// publishing should pause until false is sent to listeners.
 	for ok := range notifyFlowChan {