Unable to Perform Server-Side Stream Initialization Checks in gRPC Client-Side Streaming RPC to return error on stream creation about grpc-go HOT 3 CLOSED

grpc::Status TestV1ServiceImpl::run_session(::grpc::ServerContext *context,
                                            ::grpc::ServerReader<::test::v1::Request> *stream,
                                            ::google::protobuf::Empty *) {
  {
    auto cpu = utils::get_cpu_usage();
    if (cpu > 0) {
      printf("1111CPU usage %f exeeds 80\n", cpu);
      return grpc::Status(grpc::StatusCode::RESOURCE_EXHAUSTED, "CPU resource exhausted");
    }
  }


  proto::Request req;
  while(true) {
    auto res = stream->Read(&req);
    if (!res) {
      printf("Cancel connection. Read error\f");
      return grpc::Status::CANCELLED;
    } else {
      printf("RECEIVED!\n");
    }
  }
}

func main() {
        conn, err := createConnection()
        if err != nil {
                fmt.Println("1: ", err)
                panic(err)
        }

        ctx, _ := context.WithCancel(context.Background())

        c := test.NewTestClient(conn)
        stream, err := c.RunSession(ctx)

        if err != nil {
                fmt.Println("2: ", err)
                panic(err)
        }

        m := new(emptypb.Empty)
        for err == nil {
                if err := stream.RecvMsg(m); err != nil {
                        fmt.Println("4: ", err)
                        panic(err)
                }

        }

        fmt.Println("####EXITING####")
        fmt.Println("5: ", err)
        return
}