MCPcopy Create free account
hub / github.com/apache/arrow / Read

Method Read

cpp/src/arrow/flight/transport/grpc/grpc_client.cc:247–254  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

245 : stream_(stream) {}
246
247 Status Read(std::string* token) override {
248 pb::HandshakeResponse request;
249 if (stream_->Read(&request)) {
250 *token = std::move(*request.mutable_payload());
251 return Status::OK();
252 }
253 return FromGrpcStatus(stream_->Finish());
254 }
255
256 private:
257 std::shared_ptr<::grpc::ClientReaderWriter<pb::HandshakeRequest, pb::HandshakeResponse>>

Callers 7

AuthenticateMethod · 0.45
ReadPutMetadataMethod · 0.45
NextMethod · 0.45
ListFlightsMethod · 0.45
ListActionsMethod · 0.45
AuthenticateInternalMethod · 0.45
ReadPayloadFunction · 0.45

Calls 3

FromGrpcStatusFunction · 0.85
OKFunction · 0.50
FinishMethod · 0.45

Tested by 1

AuthenticateMethod · 0.36