fix: unsubscribe nats subscription when stream is done (#349)

formancehq · Jun 6, 2023 · 5fe6e9b · 5fe6e9b · vercel · Jun 6, 2023
1 parent 430dac7
commit 5fe6e9b
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/components/stargate/internal/server/grpc/api.go b/components/stargate/internal/server/grpc/api.go
@@ -82,6 +82,7 @@ func (s *Server) Stargate(stream api.StargateService_StargateServer) error {
 		}...)
 		return status.Errorf(codes.Internal, "cannot subscribe to nats subject")
 	}
+	defer sub.Unsubscribe()
 
 	eg, ctx := errgroup.WithContext(ctx)