From d313612786e112a779987773b6da14e9b2ef84a3 Mon Sep 17 00:00:00 2001 From: Tyler Smith Date: Thu, 25 Apr 2024 13:51:27 -0400 Subject: [PATCH] Update dropTxFeed usage. --- core/txpool/blobpool/blobpool.go | 2 +- core/txpool/legacypool/legacypool.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/core/txpool/blobpool/blobpool.go b/core/txpool/blobpool/blobpool.go index 12702dbb38..8da38a31d5 100644 --- a/core/txpool/blobpool/blobpool.go +++ b/core/txpool/blobpool/blobpool.go @@ -1504,7 +1504,7 @@ func (p *BlobPool) SubscribeTransactions(ch chan<- core.NewTxsEvent, reorgs bool // SubscribeDropTxsEvent registers a subscription of DropTxsEvent and // starts sending event to the given channel. func (p *BlobPool) SubscribeDropTxsEvent(ch chan<- core.DropTxsEvent) event.Subscription { - return p.eventScope.Track(p.dropTxFeed.Subscribe(ch)) + return p.dropTxFeed.Subscribe(ch) } // Nonce returns the next nonce of an account, with all transactions executable diff --git a/core/txpool/legacypool/legacypool.go b/core/txpool/legacypool/legacypool.go index 772d9e2d43..6794f29d9a 100644 --- a/core/txpool/legacypool/legacypool.go +++ b/core/txpool/legacypool/legacypool.go @@ -449,7 +449,7 @@ func (pool *LegacyPool) SubscribeTransactions(ch chan<- core.NewTxsEvent, reorgs // SubscribeDropTxsEvent registers a subscription of DropTxsEvent and // starts sending event to the given channel. func (pool *LegacyPool) SubscribeDropTxsEvent(ch chan<- core.DropTxsEvent) event.Subscription { - return pool.scope.Track(pool.dropTxFeed.Subscribe(ch)) + return pool.dropTxFeed.Subscribe(ch) } // SetGasTip updates the minimum gas tip required by the transaction pool for a