From 5fe6e9b80317745d70955eaf37cfebbf1bda6284 Mon Sep 17 00:00:00 2001 From: Paul Nicolas Date: Tue, 6 Jun 2023 10:41:11 +0200 Subject: [PATCH] fix: unsubscribe nats subscription when stream is done (#349) --- components/stargate/internal/server/grpc/api.go | 1 + 1 file changed, 1 insertion(+) diff --git a/components/stargate/internal/server/grpc/api.go b/components/stargate/internal/server/grpc/api.go index 4a625c3de8..b18445e1ed 100644 --- 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)