arrow_integration_testing::flight_client_scenarios::integration_test

Function receive_batch_flight_data

Source 
async fn receive_batch_flight_data(
    resp: &mut Streaming<FlightData>,
    schema: SchemaRef,
    dictionaries_by_id: &mut HashMap<i64, ArrayRef>,
) -> Option<FlightData>