Searched defs:AsyncTube (Results 1 – 5 of 5) sorted by relevance
10 pub struct AsyncTube { struct14 impl AsyncTube { impl15 pub fn new(ex: &Executor, tube: Tube) -> io::Result<AsyncTube> { in new()30 impl Deref for AsyncTube { implementation
12 pub struct AsyncTube { struct16 impl AsyncTube { impl17 pub fn new(ex: &Executor, tube: Tube) -> io::Result<AsyncTube> { in new()
565 command_tube: AsyncTube, in handle_command_tube()663 request_tube: Option<AsyncTube>, in handle_translate_request()664 response_tubes: Option<BTreeMap<u32, AsyncTube>>, in handle_translate_request() argument
407 command_tube: &AsyncTube, in handle_command_tube()
272 command_tube: &Option<AsyncTube>, in handle_command_tube()375 control_tube: &Option<AsyncTube>, in run_worker()