This commit is contained in:
Zoltán Papp
2025-06-02 16:47:29 +02:00
parent 855d21c37e
commit fbdccbc2a1

View File

@@ -988,9 +988,9 @@ func (d *Status) notifyPeerStateChangeListeners(peerID string) {
return return
} }
for _, sub := range subs { for _, sub := range subs {
select { // block the write because we do not want to miss notification
case sub.eventsChan <- struct{}{}: // must have to be sure we will run the GetPeerState() on separated thread
} sub.eventsChan <- struct{}{}
} }
} }