Searched refs:command_tube (Results 1 – 2 of 2) sorted by relevance
194 command_tube: &Tube, in handle_stats_queue()229 if let Err(e) = command_tube.send(&result) { in handle_stats_queue()248 command_tube: &AsyncTube, in handle_command_tube()254 match command_tube.next().await { in handle_command_tube()308 command_tube: Tube, in run_worker()318 let command_tube = command_tube.into_async_tube(&ex).unwrap(); in run_worker() localVariable359 &command_tube, in run_worker()366 let command = handle_command_tube(&command_tube, interrupt.clone(), config, stats_tx); in run_worker()383 command_tube.into() in run_worker()388 command_tube: Option<Tube>, field[all …]
382 command_tube: &Option<AsyncTube>, in handle_command_tube()386 let command_tube = match command_tube { in handle_command_tube() localVariable394 match command_tube.next().await { in handle_command_tube()402 command_tube in handle_command_tube()