7 use bytes::Bytes;
127         let bytes = self.get_mut(&stream)?.check_write()?;  in check_write()  localVariable
128         Ok(bytes as u64)  in check_write()
131     fn write(&mut self, stream: Resource<DynOutputStream>, bytes: Vec<u8>) -> StreamResult<()> {  in write()
132         self.get_mut(&stream)?.write(bytes.into())?;  in write()
143         bytes: Vec<u8>,  in blocking_write_and_flush()
145         if bytes.len() > 4096 {  in blocking_write_and_flush()
152             .blocking_write_and_flush(bytes.into())  in blocking_write_and_flush()
257         let bytes = self.get_mut(&stream)?.read(len)?;  in read()  localVariable
258         debug_assert!(bytes.len() <= len);  in read()
259         Ok(bytes.into())  in read()
268         let bytes = self.get_mut(&stream)?.blocking_read(len).await?;  in blocking_read()  localVariable
269         debug_assert!(bytes.len() <= len);  in blocking_read()
270         Ok(bytes.into())  in blocking_read()