| 675 | } |
| 676 | |
| 677 | arrow::Result<std::unique_ptr<FlightStreamReader>> FlightClient::DoGet( |
| 678 | const FlightCallOptions& options, const Ticket& ticket) { |
| 679 | RETURN_NOT_OK(CheckOpen()); |
| 680 | std::unique_ptr<internal::ClientDataStream> remote_stream; |
| 681 | RETURN_NOT_OK(transport_->DoGet(options, ticket, &remote_stream)); |
| 682 | std::unique_ptr<FlightStreamReader> stream_reader = |
| 683 | std::make_unique<ClientStreamReader>(std::move(remote_stream), options.read_options, |
| 684 | options.stop_token, options.memory_manager); |
| 685 | // Eagerly read the schema |
| 686 | RETURN_NOT_OK( |
| 687 | static_cast<ClientStreamReader*>(stream_reader.get())->EnsureDataStarted()); |
| 688 | return stream_reader; |
| 689 | } |
| 690 | |
| 691 | arrow::Result<FlightClient::DoPutResult> FlightClient::DoPut( |
| 692 | const FlightCallOptions& options, const FlightDescriptor& descriptor, |
nothing calls this directly
no test coverage detected