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)
 	}
 }