fix(fxgcppubsub): Fixed nack reactor

ankorstore · Jul 10, 2024 · 783f5d3 · 783f5d3
1 parent ff72fc6
commit 783f5d3
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/fxgcppubsub/reactor/supervisor.go b/fxgcppubsub/reactor/supervisor.go
@@ -49,5 +49,7 @@ func (s *DefaultWaiterSupervisor) StopWaiter(target string, data any, err error)
 
 	if waiter, found := s.waiters[target]; found {
 		waiter.Stop(data, err)
+
+		delete(s.waiters, target)
 	}
 }