Method do_get

arrow-flight/src/sql/client.rs:278–292

Given a flight ticket, request to be sent the stream. Returns record batch stream reader

(
        &mut self,
        ticket: impl IntoRequest<Ticket>,
    )

    /// Given a flight ticket, request to be sent the stream. Returns record batch stream reader
    pub async fn do_get(
        &mut self,
        ticket: impl IntoRequest<Ticket>,
    ) -> Result<FlightRecordBatchStream> {
        let req = self.set_request_headers(ticket.into_request())?;

        let (md, response_stream, _ext) = self.flight_client.do_get(req).await?.into_parts();
        let (response_stream, trailers) = extract_lazy_trailers(response_stream);

        Ok(FlightRecordBatchStream::new_from_flight_data(
            response_stream.map_err(|status| status.into()),
        )
        .with_headers(md)
        .with_trailers(trailers))
    }

    /// Push a stream to the flight service associated with a particular flight stream.
    pub async fn do_put(