Searched refs:into_async_tube (Results 1 – 3 of 3) sorted by relevance
66 pub fn into_async_tube(self, ex: &Executor) -> Result<AsyncTube> { in into_async_tube() method
318 let command_tube = command_tube.into_async_tube(&ex).unwrap(); in run_worker()
901 .map(|c| c.into_async_tube(&ex).expect("failed to create async tube")); in activate()