diff --git a/eth/filters/api.go b/eth/filters/api.go index 6a48a9413c..2cd27c31da 100644 --- a/eth/filters/api.go +++ b/eth/filters/api.go @@ -352,6 +352,7 @@ func (api *FilterAPI) Logs(ctx context.Context, crit FilterCriteria) (*rpc.Subsc notifier.Notify(rpcSub.ID, &log) case logs := <-rmLogsCh: for _, log := range logs { + log := log if log.Removed { rmLogs = append(rmLogs, log) }