Method RunExchangeGet

cpp/src/arrow/flight/test_flight_server.cc:185–194

A simple example - act like DoGet.

// A simple example - act like DoGet.
Status TestFlightServer::RunExchangeGet(std::unique_ptr<FlightMessageReader> reader,
                                        std::unique_ptr<FlightMessageWriter> writer) {
  RETURN_NOT_OK(writer->Begin(ExampleIntSchema()));
  RecordBatchVector batches;
  RETURN_NOT_OK(ExampleIntBatches(&batches));
  for (const auto& batch : batches) {
    RETURN_NOT_OK(writer->WriteRecordBatch(*batch));
  }
  return Status::OK();
}

// A simple example - act like DoPut
Status TestFlightServer::RunExchangePut(std::unique_ptr<FlightMessageReader> reader,