forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-07-22 20:56:42 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

core: track newPayloadFeed subscriptions in scope

Browse source 
Wrap SubscribeNewPayloadEvent with bc.scope.Track() to ensure
subscriptions are properly cleaned up on shutdown, consistent
with other BlockChain subscription methods. Also fix typo in
the method's doc comment.
This commit is contained in:
Andrew Davis 2025-12-22 10:43:16 +10:00
parent 63c4383bd2
commit 2382d05fb2
No known key found for this signature in database
GPG key ID: 30AB5B89A109D044
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
core/blockchain_reader.go
View file

@ -523,9 +523,9 @@ func (bc *BlockChain) SubscribeBlockProcessingEvent(ch chan<- bool) event.Subscr
return bc.scope.Track(bc.blockProcFeed.Subscribe(ch)) return bc.scope.Track(bc.blockProcFeed.Subscribe(ch))
} }
// / SubscribeNewPayloadEvent registers a subscription for NewPayloadEvent. // SubscribeNewPayloadEvent registers a subscription for NewPayloadEvent.
func (bc *BlockChain) SubscribeNewPayloadEvent(ch chan<- NewPayloadEvent) event.Subscription { func (bc *BlockChain) SubscribeNewPayloadEvent(ch chan<- NewPayloadEvent) event.Subscription {
return bc.newPayloadFeed.Subscribe(ch) return bc.scope.Track(bc.newPayloadFeed.Subscribe(ch))
} }
// SendNewPayloadEvent sends a NewPayloadEvent to subscribers. // SendNewPayloadEvent sends a NewPayloadEvent to subscribers.