Searched refs:cancel_task (Results 1 – 1 of 1) sorted by relevance
163 let err = cancel_task(&self.core().stage); in shutdown()384 fn cancel_task<T: Future>(stage: &CoreStage<T>) -> JoinError { in cancel_task() function438 Err(_) => PollFuture::Complete(Err(cancel_task(core)), true), in poll_future()