diff --git a/v2/pkg/engine/resolve/resolve.go b/v2/pkg/engine/resolve/resolve.go index 016728719..cd25e1437 100644 --- a/v2/pkg/engine/resolve/resolve.go +++ b/v2/pkg/engine/resolve/resolve.go @@ -626,8 +626,8 @@ func (r *Resolver) handleRemoveSubscription(id SubscriptionIdentifier) { removed := 0 for u := range r.triggers { trig := r.triggers[u] - removed += r.shutdownTriggerSubscriptions(u, func(a SubscriptionIdentifier) bool { - return a == id + removed += r.shutdownTriggerSubscriptions(u, func(sID SubscriptionIdentifier) bool { + return sID == id }) if len(trig.subscriptions) == 0 { r.shutdownTrigger(trig.id)