fix_: panic: send on closed channel (#5352)
This commit is contained in:
parent
68acef62d4
commit
63e8750aea
|
@ -172,7 +172,6 @@ func (m *EnvelopesMonitor) handleEnvelopeEvents() {
|
||||||
events := make(chan types.EnvelopeEvent, 100) // must be buffered to prevent blocking waku
|
events := make(chan types.EnvelopeEvent, 100) // must be buffered to prevent blocking waku
|
||||||
sub := m.w.SubscribeEnvelopeEvents(events)
|
sub := m.w.SubscribeEnvelopeEvents(events)
|
||||||
defer func() {
|
defer func() {
|
||||||
close(events)
|
|
||||||
sub.Unsubscribe()
|
sub.Unsubscribe()
|
||||||
}()
|
}()
|
||||||
for {
|
for {
|
||||||
|
|
Loading…
Reference in New Issue