From 743cd0bc326743c4064bc5f0aaa1a9fd3a80061b Mon Sep 17 00:00:00 2001 From: Felix Lange Date: Thu, 14 Sep 2023 10:46:20 +0200 Subject: [PATCH] eth/filters: add some newlines Signed-off-by: jsvisa --- eth/filters/api.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/eth/filters/api.go b/eth/filters/api.go index 1fd0307a80..ef2351613f 100644 --- a/eth/filters/api.go +++ b/eth/filters/api.go @@ -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) liveOnly = true histLogs = nil + case logs := <-liveLogs: if len(logs) == 0 { continue @@ -405,6 +406,7 @@ func (api *FilterAPI) histLogs(notifier notifier, rpcSub *rpc.Subscription, from // Send them all. notifyLogsIf(notifier, rpcSub.ID, logs, nil) } + case logs := <-histLogs: if len(logs) == 0 { continue @@ -428,6 +430,7 @@ func (api *FilterAPI) histLogs(notifier notifier, rpcSub *rpc.Subscription, from notifyLogsIf(notifier, rpcSub.ID, logs, nil) // Assuming batch = all logs of a single block delivered = logs[0].BlockNumber + case <-rpcSub.Err(): // client send an unsubscribe request return case <-notifier.Closed(): // connection dropped