Lines Matching refs:wr
205 async fn put(id: u32, wr: SplitWriteHalf) {
208 let arc_wr = Arc::new(Mutex::new(wr));
219 let mut wr = arc_wr.lock().await;
220 let write_result = wr.write_all(data.as_slice()).await;
231 let mut wr = arc_wr.lock().await;
232 let _ = wr.shutdown().await;
673 let (rd, wr) = stream.into_split();
679 TcpWriteStreamMap::put(client_context.id, wr).await;
738 let (rd, wr) = stream.into_split();
739 TcpWriteStreamMap::put(ctx.id, wr).await;