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