eth/filters: terminate pending tx subscription on error ethereum#32794 (#1901)

wit765 · web-flow · commit 3fb8b87a87fe · 2026-01-04T17:31:29.000+05:30
diff --git a/eth/filters/api.go b/eth/filters/api.go
@@ -141,6 +141,7 @@ func (api *FilterAPI) NewPendingTransactionFilter() rpc.ID {
 				api.filtersMu.Lock()
 				delete(api.filters, pendingTxSub.ID)
 				api.filtersMu.Unlock()
+				pendingTxSub.Unsubscribe()
 				return
 			}
 		}

Original file line number	Diff line number	Diff line change
`@@ -141,6 +141,7 @@ func (api *FilterAPI) NewPendingTransactionFilter() rpc.ID {`
`141`	`141`	`api.filtersMu.Lock()`
`142`	`142`	`delete(api.filters, pendingTxSub.ID)`
`143`	`143`	`api.filtersMu.Unlock()`
	`144`	`+ pendingTxSub.Unsubscribe()`
`144`	`145`	`return`
`145`	`146`	`}`
`146`	`147`	`}`