arrow_integration_testing::flight_client_scenarios::integration_test

Function consume_flight_location

Source 
async fn consume_flight_location(
    location: Location,
    ticket: Ticket,
    expected_data: &[RecordBatch],
) -> Result<(), Box<dyn Error + Send + Sync + 'static>>