ensure_head_concurrency

datafusion::test::object_store

Function ensure_head_concurrency 

Source 
pub fn ensure_head_concurrency(
    object_store: Arc<dyn ObjectStore>,
    concurrency: usize,
) -> Arc<dyn ObjectStore>
Expand description

Blocks the object_store head call until concurrency number of calls are pending.