[][src]Function workqueue::work

pub async fn work<T, W, F, C>(
    context: C,
    starting_items: SegQueue<W>,
    worker: F
) -> Result<HashMap<W, T>, JoinError> where
    W: Debug + Clone + Eq + Hash + Send + Sync + 'static,
    F: Fn(W, Arc<SegQueue<W>>, Arc<C>) -> Pin<Box<dyn Future<Output = T> + Send + Sync + 'static>> + Send + Sync + 'static,
    T: Send + Sync + 'static,