diff --git a/core/bloombits/matcher.go b/core/bloombits/matcher.go index cf799c8324..d8f932041b 100644 --- a/core/bloombits/matcher.go +++ b/core/bloombits/matcher.go @@ -630,16 +630,13 @@ func (s *MatcherSession) Multiplex(batch int, wait time.Duration, mux chan chan request <- &Retrieval{Bit: bit, Sections: sections, Context: s.ctx} result := <-request - - // Deliver a result before s.Close() to avoid a deadlock - s.deliverSections(result.Bit, result.Sections, result.Bitsets) - if result.Error != nil { s.errLock.Lock() s.err = result.Error s.errLock.Unlock() s.Close() } + s.deliverSections(result.Bit, result.Sections, result.Bitsets) } } }