diff --git a/api/subscriptions/pending_tx.go b/api/subscriptions/pending_tx.go index 431f29f1e..e8b2d065a 100644 --- a/api/subscriptions/pending_tx.go +++ b/api/subscriptions/pending_tx.go @@ -72,7 +72,7 @@ func (p *pendingTx) DispatchLoop(done <-chan struct{}) { func (p *pendingTx) dispatch(tx *tx.Transaction, done <-chan struct{}) { p.mu.RLock() - defer p.mu.Unlock() + defer p.mu.RUnlock() for lsn := range p.listeners { select {