From 783f5d30930fdb677bd8d38cf58ffac6fde14d88 Mon Sep 17 00:00:00 2001
From: Jonathan Vuillemin <ekkinox@gmail.com>
Date: Wed, 10 Jul 2024 11:52:26 +0200
Subject: [PATCH] fix(fxgcppubsub): Fixed nack reactor

---
 fxgcppubsub/reactor/supervisor.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/fxgcppubsub/reactor/supervisor.go b/fxgcppubsub/reactor/supervisor.go
index 5a85408..31557ef 100644
--- 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)
 	}
 }