diff --git a/core/blockchain_reader.go b/core/blockchain_reader.go index e93ff5c33c..ee15c152c4 100644 --- a/core/blockchain_reader.go +++ b/core/blockchain_reader.go @@ -523,9 +523,9 @@ func (bc *BlockChain) SubscribeBlockProcessingEvent(ch chan<- bool) event.Subscr 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 { - return bc.newPayloadFeed.Subscribe(ch) + return bc.scope.Track(bc.newPayloadFeed.Subscribe(ch)) } // SendNewPayloadEvent sends a NewPayloadEvent to subscribers.