Method get_flight_info_for_command

arrow-flight/src/sql/client.rs:135–143

(
        &mut self,
        cmd: M,
    )

    }

    async fn get_flight_info_for_command<M: ProstMessageExt>(
        &mut self,
        cmd: M,
    ) -> Result<FlightInfo> {
        let descriptor = FlightDescriptor::new_cmd(cmd.as_any().encode_to_vec());
        let req = self.set_request_headers(descriptor.into_request())?;
        let fi = self.flight_client.get_flight_info(req).await?.into_inner();
        Ok(fi)
    }

    /// Execute a query on the server.
    pub async fn execute(