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

execute different subscription in parallel way

Browse source
This commit is contained in:
maskpp 2025-10-19 17:39:49 +08:00
parent 0ec63272bf
commit 2005bf6b67
1 changed files with 14 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
eth/filters/filter_system.go
View file

@ -439,10 +439,13 @@ func (es *EventSystem) handleTxsEvent(filters filterIndex, ev core.NewTxsEvent)
} }
func (es *EventSystem) handleChainEvent(filters filterIndex, ev core.ChainEvent) { func (es *EventSystem) handleChainEvent(filters filterIndex, ev core.ChainEvent) {
go func() {
for _, f := range filters[BlocksSubscription] { for _, f := range filters[BlocksSubscription] {
f.headers <- ev.Header f.headers <- ev.Header
} }
}()
go func() {
// Handle transaction receipts subscriptions when a new block is added // Handle transaction receipts subscriptions when a new block is added
for _, f := range filters[TransactionReceiptsSubscription] { for _, f := range filters[TransactionReceiptsSubscription] {
matchedReceipts := filterReceipts(f.txHashes, ev) matchedReceipts := filterReceipts(f.txHashes, ev)
@ -450,6 +453,7 @@ func (es *EventSystem) handleChainEvent(filters filterIndex, ev core.ChainEvent)
f.receipts <- matchedReceipts f.receipts <- matchedReceipts
} }
} }
}()
} }
// eventLoop (un)installs filters and processes mux events. // eventLoop (un)installs filters and processes mux events.