diff --git a/ctxc/filters/api.go b/ctxc/filters/api.go index 7ce9b08662..c2e0243dfa 100644 --- a/ctxc/filters/api.go +++ b/ctxc/filters/api.go @@ -86,7 +86,11 @@ func (api *FilterAPI) timeoutLoop(timeout time.Duration) { ticker := time.NewTicker(timeout) defer ticker.Stop() for { - <-ticker.C + select { + case <-ticker.C: + case <-api.events.chainSub.Err(): + return + } api.filtersMu.Lock() for id, f := range api.filters { select {