Searched refs:buf (Results 1 – 5 of 5) sorted by relevance
| /xiu/library/logger/src/ |
| H A D | target.rs | 20 fn write(&mut self, buf: &[u8]) -> io::Result<usize> { in write()
21 match self.cur_file_handler.lock().unwrap().write(buf) { in write()
|
| /xiu/library/bytesio/src/ |
| H A D | bytes_writer.rs | 97 pub fn write(&mut self, buf: &[u8]) -> Result<(), BytesWriteError> { in write()
98 self.bytes.write_all(buf)?; in write()
102 pub fn prepend(&mut self, buf: &[u8]) -> Result<(), BytesWriteError> { in prepend()
105 self.bytes.write_all(buf)?; in prepend()
187 pub fn write(&mut self, buf: &[u8]) -> Result<(), BytesWriteError> { in write()
188 self.bytes_writer.write(buf) in write()
|
| H A D | bytesio.rs | 83 let mut buf = vec![0; 4096]; in read() localVariable
84 let len = self.socket.recv(&mut buf).await?; in read()
86 rv.put(&buf[..len]); in read()
|
| /xiu/protocol/rtsp/src/rtp/rtcp/ |
| H A D | rtcp_context.rs | 143 let mut buf = BytesMut::with_capacity(name.len()); in generate_app() localVariable
144 buf.extend_from_slice(name.as_bytes()); in generate_app()
148 name: buf, in generate_app()
|
| /xiu/protocol/rtmp/src/amf0/ |
| H A D | amf0_reader.rs | 171 let mut buf = [0; 8]; in test_byte_order() localVariable
172 BigEndian::write_f64(&mut buf, phi); in test_byte_order()
173 assert_eq!(phi, BigEndian::read_f64(&buf)); in test_byte_order()
|