| 1244 | : device_(std::move(device)), context_(std::move(context)) {} |
| 1245 | |
| 1246 | Status DoGet(const ServerCallContext&, const Ticket&, |
| 1247 | std::unique_ptr<FlightDataStream>* data_stream) override { |
| 1248 | RETURN_NOT_OK(ExampleIntBatches(&batches_)); |
| 1249 | ARROW_ASSIGN_OR_RAISE(auto batch_reader, RecordBatchReader::Make(batches_)); |
| 1250 | *data_stream = std::make_unique<RecordBatchStream>(batch_reader); |
| 1251 | return Status::OK(); |
| 1252 | } |
| 1253 | |
| 1254 | Status DoPut(const ServerCallContext&, std::unique_ptr<FlightMessageReader> reader, |
| 1255 | std::unique_ptr<FlightMetadataWriter> writer) override { |
nothing calls this directly
no test coverage detected