srt
pub async fn multiplex( addr: SocketAddr, latency: Duration) -> Result<impl Stream<Item = Result<(Connection, PackChan), Error>>, Error>