From e1a407d2c09842ad3a6d83305bea5f9076c60b91 Mon Sep 17 00:00:00 2001
From: Daniel Liu <139250065@qq.com>
Date: Thu, 28 Aug 2025 18:57:27 +0800
Subject: [PATCH] eth/filters: reuse func handleLogs for Removed logs #27438
 (#1390)

---
 eth/filters/filter_system.go | 11 +----------
 1 file changed, 1 insertion(+), 10 deletions(-)

diff --git a/eth/filters/filter_system.go b/eth/filters/filter_system.go
index fdc7d85410..8bf0ca6946 100644
--- a/eth/filters/filter_system.go
+++ b/eth/filters/filter_system.go
@@ -445,15 +445,6 @@ func (es *EventSystem) handlePendingLogs(filters filterIndex, ev []*types.Log) {
 	}
 }
 
-func (es *EventSystem) handleRemovedLogs(filters filterIndex, ev core.RemovedLogsEvent) {
-	for _, f := range filters[LogsSubscription] {
-		matchedLogs := filterLogs(ev.Logs, f.logsCrit.FromBlock, f.logsCrit.ToBlock, f.logsCrit.Addresses, f.logsCrit.Topics)
-		if len(matchedLogs) > 0 {
-			f.logs <- matchedLogs
-		}
-	}
-}
-
 func (es *EventSystem) handleTxsEvent(filters filterIndex, ev core.NewTxsEvent) {
 	for _, f := range filters[PendingTransactionsSubscription] {
 		f.txs <- ev.Txs
@@ -574,7 +565,7 @@ func (es *EventSystem) eventLoop() {
 		case ev := <-es.logsCh:
 			es.handleLogs(index, ev)
 		case ev := <-es.rmLogsCh:
-			es.handleRemovedLogs(index, ev)
+			es.handleLogs(index, ev.Logs)
 		case ev := <-es.pendingLogsCh:
 			es.handlePendingLogs(index, ev)
 		case ev := <-es.chainCh: