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

eth/filters: add some newlines

Browse source 
Signed-off-by: jsvisa <delweng@gmail.com>
This commit is contained in:
Felix Lange 2023-09-14 10:46:20 +02:00 committed by jsvisa
parent 3aa0f5bad2
commit 743cd0bc32
1 changed files with 3 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
eth/filters/api.go
View file

@ -374,6 +374,7 @@ func (api *FilterAPI) histLogs(notifier notifier, rpcSub *rpc.Subscription, from
logger.Info("History logs delivery finished, and now enter into live mode", "delivered", delivered) logger.Info("History logs delivery finished, and now enter into live mode", "delivered", delivered)
liveOnly = true liveOnly = true
histLogs = nil histLogs = nil
case logs := <-liveLogs: case logs := <-liveLogs:
if len(logs) == 0 { if len(logs) == 0 {
continue continue
@ -405,6 +406,7 @@ func (api *FilterAPI) histLogs(notifier notifier, rpcSub *rpc.Subscription, from
// Send them all. // Send them all.
notifyLogsIf(notifier, rpcSub.ID, logs, nil) notifyLogsIf(notifier, rpcSub.ID, logs, nil)
} }
case logs := <-histLogs: case logs := <-histLogs:
if len(logs) == 0 { if len(logs) == 0 {
continue continue
@ -428,6 +430,7 @@ func (api *FilterAPI) histLogs(notifier notifier, rpcSub *rpc.Subscription, from
notifyLogsIf(notifier, rpcSub.ID, logs, nil) notifyLogsIf(notifier, rpcSub.ID, logs, nil)
// Assuming batch = all logs of a single block // Assuming batch = all logs of a single block
delivered = logs[0].BlockNumber delivered = logs[0].BlockNumber
case <-rpcSub.Err(): // client send an unsubscribe request case <-rpcSub.Err(): // client send an unsubscribe request
return return
case <-notifier.Closed(): // connection dropped case <-notifier.Closed(): // connection dropped