Searched defs:SplitReadHalf (Results 1 – 6 of 6) sorted by relevance
28 async fn read_frame(rd: &mut SplitReadHalf, expected_size: usize) -> io::Result<Vec<u8>> { in read_frame()
248 pub async fn start(rd: SplitReadHalf) { in start()
36 rd: &mut SplitReadHalf, in handshake_with_daemon()
186 rd: &mut SplitReadHalf, in handshake_with_client()
345 mut rd: SplitReadHalf, in tcp_handle_deamon()
59 async fn put(id: u32, rd: SplitReadHalf) { in put()367 pub async fn recv_tcp_msg(session_id: u32, channel_id: u32, mut rd: SplitReadHalf, cid: u32) { in recv_tcp_msg()