diff --git a/internal/grpcService/taskProcessor.go b/internal/grpcService/taskProcessor.go index 93986bb..8b371f0 100644 --- a/internal/grpcService/taskProcessor.go +++ b/internal/grpcService/taskProcessor.go @@ -91,5 +91,9 @@ func (r *repoServer) SendResult(stream pb.TaskProcessor_SendResultServer) error } } + if err := stream.SendAndClose(&emptypb.Empty{}); err != nil { + return err + } + return nil }