Lines Matching refs:rx
170 mut rx: mpsc::BoundedReceiver<Vec<u8>>,
208 recv_res = rx.recv() => {
248 crate::debug!("rx recv failed: {e:?}");
320 let (tx, rx) = ylong_runtime::sync::mpsc::bounded_channel::<Vec<u8>>(16);
328 rx,
552 async fn watch_pipe_states(rx: &mut mpsc::BoundedReceiver<Vec<u8>>, child_in: &mut ChildStdin) -> io::Result<()> {
553 match rx.try_recv() {
602 mut rx: mpsc::BoundedReceiver<Vec<u8>>,
705 if (watch_pipe_states(&mut rx, &mut child_in).await).is_err() {
745 let (tx, rx) = ylong_runtime::sync::mpsc::bounded_channel::<Vec<u8>>(16);
753 rx,