arrow_integration_testing::flight_server_scenarios::integration_test

Function save_uploaded_chunks

Source 
async fn save_uploaded_chunks(
    uploaded_chunks: Arc<Mutex<HashMap<String, IntegrationDataset>>>,
    schema_ref: Arc<Schema>,
    input_stream: Streaming<FlightData>,
    response_tx: Sender<Result<PutResult, Status>>,
    schema: Schema,
    key: String,
) -> Result<(), Status>