diff --git a/eth/filters/api.go b/eth/filters/api.go index e4e2246de6..2ec5ff62a2 100644 --- 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 } }