From beec73e12dfad8417b623b3d45fcd470610a68f0 Mon Sep 17 00:00:00 2001 From: A1lo Date: Fri, 3 Feb 2023 15:24:12 +0800 Subject: [PATCH] fix: always call cancel func --- app/log/command/command.go | 1 + 1 file changed, 1 insertion(+) diff --git a/app/log/command/command.go b/app/log/command/command.go index 2524c08bf..b23e25d59 100644 --- a/app/log/command/command.go +++ b/app/log/command/command.go @@ -44,6 +44,7 @@ func (s *LoggerServer) FollowLog(_ *FollowLogRequest, stream LoggerService_Follo return newError("logger not support following") } ctx, cancel := context.WithCancel(stream.Context()) + defer cancel() f := func(msg cmlog.Message) { err := stream.Send(&FollowLogResponse{ Message: msg.String(),