Skip to content

Commit 55f6f27

Browse files
nvxjohto
authored andcommitted
Fix Listen() hanging indefinitely when listener is closed
1 parent 90697d6 commit 55f6f27

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

notify.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -725,6 +725,9 @@ func (l *Listener) Close() error {
725725
}
726726
l.isClosed = true
727727

728+
// Unblock calls to Listen()
729+
l.reconnectCond.Broadcast()
730+
728731
return nil
729732
}
730733

0 commit comments

Comments
 (0)