Skip to content

Commit

Permalink
core/txpool: SubscribeNewHeadEvent unused
Browse files Browse the repository at this point in the history
  • Loading branch information
darioush committed Feb 26, 2024
1 parent d4c07fb commit 45d3b34
Showing 1 changed file with 0 additions and 7 deletions.
7 changes: 0 additions & 7 deletions core/txpool/txpool.go
Original file line number Diff line number Diff line change
Expand Up @@ -238,7 +238,6 @@ func (p *TxPool) loop(head *types.Header, chain BlockChain) {
case event := <-newHeadCh:
// Chain moved forward, store the head for later consumption
newHead = event.Block.Header()
p.headFeed.Send(core.NewTxPoolHeadEvent{Head: newHead})

case head := <-resetDone:
// Previous reset finished, update the old head and allow a new reset
Expand Down Expand Up @@ -436,12 +435,6 @@ func (p *TxPool) SubscribeNewTxsEvent(ch chan<- core.NewTxsEvent) event.Subscrip
return p.subs.Track(event.JoinSubscriptions(subs...))
}

// SubscribeNewHeadEvent registers a subscription of NewHeadEvent and
// starts sending event to the given channel.
func (p *TxPool) SubscribeNewHeadEvent(ch chan<- core.NewTxPoolHeadEvent) event.Subscription {
return p.subs.Track(p.headFeed.Subscribe(ch))
}

// SubscribeNewReorgEvent registers a subscription of NewReorgEvent and
// starts sending event to the given channel.
func (p *TxPool) SubscribeNewReorgEvent(ch chan<- core.NewTxPoolReorgEvent) event.Subscription {
Expand Down

0 comments on commit 45d3b34

Please sign in to comment.