Searched refs:Mux (Results 1 – 3 of 3) sorted by relevance
31 pub struct Mux { struct39 impl Mux { argument42 let m = Mux { in new()54 Mux::read_loop(buffer_size, next_conn, closed_ch_rx, endpoints).await; in new()113 if let Err(err) = Mux::dispatch(&buf[..n], &endpoints).await { in read_loop()
15 let mut m = Mux::new(Config { in pipe_memory()32 let mut m = Mux::new(Config { in test_no_endpoints()37 Mux::dispatch(&[0], &m.endpoints).await?; in test_no_endpoints()109 let mut m = Mux::new(Config { in test_non_fatal_read()
22 use crate::mux::{Config, Mux};60 mux: Option<Mux>,190 internal.mux = Some(Mux::new(config)); in start()