Method DoExchange

cpp/src/arrow/flight/transport_server.cc:335–344

}

Status ServerTransport::DoExchange(const ServerCallContext& context,
                                   ServerDataStream* stream) {
  std::unique_ptr<TransportMessageReader> reader(
      new TransportMessageReader(stream, memory_manager_));
  std::unique_ptr<FlightMessageWriter> writer(new TransportMessageWriter(stream));
  RETURN_NOT_OK(reader->Init());
  RETURN_NOT_OK(base_->DoExchange(context, std::move(reader), std::move(writer)));
  RETURN_NOT_OK(stream->WritesDone());
  return Status::OK();
}

}  // namespace internal
}  // namespace flight