Fix Listen() hanging indefinitely when listener is closed

lib · Aug 22, 2018 · 55f6f27 · 55f6f27
1 parent 90697d6
commit 55f6f27
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/notify.go b/notify.go
@@ -725,6 +725,9 @@ func (l *Listener) Close() error {
 	}
 	l.isClosed = true
 
+	// Unblock calls to Listen()
+	l.reconnectCond.Broadcast()
+
 	return nil
 }