Merge pull request #597 from libotony/fix-tx-sub

fix unexpected race in tx subscription
vechain · Jul 19, 2023 · f4d2f2a · f4d2f2a
2 parents b2704f3 + 81b5997
commit f4d2f2a
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/api/subscriptions/pending_tx.go b/api/subscriptions/pending_tx.go
@@ -17,7 +17,7 @@ import (
 type pendingTx struct {
  txPool *txpool.TxPool
  listeners map[chan *tx.Transaction]struct{}
- mu sync.RWMutex
+ mu sync.Mutex
 }
 
 func newPendingTx(txPool *txpool.TxPool) *pendingTx {
@@ -71,7 +71,7 @@ func (p *pendingTx) DispatchLoop(done <-chan struct{}) {
 }
 
 func (p *pendingTx) dispatch(tx *tx.Transaction, done <-chan struct{}) {
- p.mu.RLock()
+ p.mu.Lock()
  defer p.mu.Unlock()
 
  for lsn := range p.listeners {