Lines Matching refs:read
126 fn buffer<'a>(&'a self, read: &'a R) -> &'a [u8]; in buffer()
128 fn advance(&mut self, read: &mut R, len: usize); in advance()
131 fn advance_pin(&mut self, read: Pin<&mut R>, len: usize); in advance_pin()
136 fn extend_buf_sync(&mut self, read: &mut R) -> io::Result<usize>; in extend_buf_sync()
145 read: Pin<&mut R>, in poll_extend_buf()
155 read: Pin<&mut R>, in poll_extend_buf()
158 fn extend_buf<'a>(&'a mut self, read: Pin<&'a mut R>) -> ExtendBuf<'a, Self, R> in extend_buf()
168 read: Pin<&'a mut R>
181 me.buffer.poll_extend_buf(cx, me.read.as_mut()) in poll()
210 fn extend_buf_sync(&mut self, read: &mut R) -> io::Result<usize> { in extend_buf_sync()
211 extend_buf_sync(&mut self.0, read) in extend_buf_sync()
223 read: Pin<&mut R>, in poll_extend_buf()
225 poll_extend_buf(&mut self.0, cx, read) in poll_extend_buf()
228 fn extend_buf<'a>(&'a mut self, read: Pin<&'a mut R>) -> ExtendBuf<'a, Self, R> { in extend_buf()
238 ExtendBuf { buffer: self, read } in extend_buf()
250 read: Pin<&mut R>, in poll_extend_buf()
255 read.poll_read_buf(cx, &mut Bytes05(&mut self.0)) in poll_extend_buf()
278 read: Pin<&mut R>, in poll_extend_buf()
280 tokio_03_read_buf(cx, read, &mut self.0) in poll_extend_buf()
287 read: Pin<&mut impl tokio_03_dep::io::AsyncRead>, in tokio_03_read_buf()
295 ready!(read.poll_read(cx, &mut buf))?; in tokio_03_read_buf()
311 read: Pin<&mut R>, in poll_extend_buf()
313 tokio_read_buf(read, cx, &mut self.0) in poll_extend_buf()
319 read: Pin<&mut impl tokio_dep::io::AsyncRead>, in tokio_read_buf()
327 tokio_util::io::poll_read_buf(read, cx, bs) in tokio_read_buf()
337 fn buffer<'a>(&'a self, read: &'a BufReader<R>) -> &'a [u8] { in buffer()
338 &read.buf in buffer()
341 fn advance(&mut self, read: &mut BufReader<R>, len: usize) { in advance()
342 read.buf.advance(len); in advance()
346 fn advance_pin(&mut self, read: Pin<&mut BufReader<R>>, len: usize) { in advance_pin()
347 read.project().buf.advance(len); in advance_pin()
355 fn extend_buf_sync(&mut self, read: &mut BufReader<R>) -> io::Result<usize> { in extend_buf_sync()
356 extend_buf_sync(&mut read.buf, &mut read.inner) in extend_buf_sync()
360 fn extend_buf_sync<R>(buf: &mut BytesMut, read: &mut R) -> io::Result<usize> in extend_buf_sync()
380 let n = read.read(bs)?; in extend_buf_sync()
418 read: Pin<&mut BufReader<R>>, in poll_extend_buf()
420 let me = read.project(); in poll_extend_buf()
437 read: Pin<&mut BufReader<R>>, in poll_extend_buf()
439 let me = read.project(); in poll_extend_buf()
453 read: Pin<&mut BufReader<R>>, in poll_extend_buf()
455 let me = read.project(); in poll_extend_buf()
469 read: Pin<&mut BufReader<R>>, in poll_extend_buf()
471 let me = read.project(); in poll_extend_buf()
478 mut read: Pin<&'a mut BufReader<R>>, in extend_buf()
480 let me = read.as_mut().project(); in extend_buf()
491 ExtendBuf { buffer: self, read } in extend_buf()
499 read: Pin<&mut R>, in poll_extend_buf()
516 let n = ready!(read.poll_read(cx, bs))?; in poll_extend_buf()
546 let nread = rem.read(buf)?; in poll_read()
735 fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> { in read() method
740 let res = self.read(buf); in read()
746 rem.read(buf)? in read()
794 let mut read = BufReader::with_capacity(3, &[1u8, 2, 3, 4, 5, 6, 7, 8, 9, 0][..]); in buf_reader() localVariable
797 read.read(&mut buf).await.unwrap(); in buf_reader()
801 read.read(&mut buf).await.unwrap(); in buf_reader()
805 read.read(&mut buf).await.unwrap(); in buf_reader()
809 read.read(&mut buf).await.unwrap(); in buf_reader()
815 let mut read = BufReader::with_capacity(3, &[1u8, 2, 3, 4, 5, 6, 7, 8, 9, 0][..]); in buf_reader_buf() localVariable
818 read.read_buf(&mut buf).await.unwrap(); in buf_reader_buf()
821 read.read_buf(&mut buf).await.unwrap(); in buf_reader_buf()
827 let read = BufReader::with_capacity(3, &[1u8, 2, 3, 4, 5, 6, 7, 8, 9, 0][..]); in buf_reader_extend_buf() localVariable
828 futures_03_dep::pin_mut!(read); in buf_reader_extend_buf()
830 assert_eq!(read.as_mut().extend_buf_tokio_02().await.unwrap(), 3); in buf_reader_extend_buf()
831 assert_eq!(read.buffer(), [1, 2, 3]); in buf_reader_extend_buf()
833 assert_eq!(read.as_mut().extend_buf_tokio_02().await.unwrap(), 7); in buf_reader_extend_buf()
834 assert_eq!(read.buffer(), [1, 2, 3, 4, 5, 6, 7, 8, 9, 0]); in buf_reader_extend_buf()
861 let mut read = BufReader::with_capacity(3, &[1u8, 2, 3, 4, 5, 6, 7, 8, 9, 0][..]); in buf_reader() localVariable
864 read.read(&mut buf).await.unwrap(); in buf_reader()
868 read.read(&mut buf).await.unwrap(); in buf_reader()
872 read.read(&mut buf).await.unwrap(); in buf_reader()
876 read.read(&mut buf).await.unwrap(); in buf_reader()
882 let mut read = BufReader::with_capacity(3, &[1u8, 2, 3, 4, 5, 6, 7, 8, 9, 0][..]); in buf_reader_buf() localVariable
885 read.read_buf(&mut buf).await.unwrap(); in buf_reader_buf()
888 read.read_buf(&mut buf).await.unwrap(); in buf_reader_buf()
894 let read = BufReader::with_capacity(3, &[1u8, 2, 3, 4, 5, 6, 7, 8, 9, 0][..]); in buf_reader_extend_buf() localVariable
895 futures_03_dep::pin_mut!(read); in buf_reader_extend_buf()
897 assert_eq!(read.as_mut().extend_buf_tokio().await.unwrap(), 3); in buf_reader_extend_buf()
898 assert_eq!(read.buffer(), [1, 2, 3]); in buf_reader_extend_buf()
900 assert_eq!(read.as_mut().extend_buf_tokio().await.unwrap(), 7); in buf_reader_extend_buf()
901 assert_eq!(read.buffer(), [1, 2, 3, 4, 5, 6, 7, 8, 9, 0]); in buf_reader_extend_buf()
914 let mut read = BufReader::with_capacity(3, &[1u8, 2, 3, 4, 5, 6, 7, 8, 9, 0][..]); in buf_reader() localVariable
917 read.read(&mut buf).unwrap(); in buf_reader()
921 read.read(&mut buf).unwrap(); in buf_reader()
925 read.read(&mut buf).unwrap(); in buf_reader()
929 read.read(&mut buf).unwrap(); in buf_reader()
935 let mut read = BufReader::with_capacity(3, &[1u8, 2, 3, 4, 5, 6, 7, 8, 9, 0][..]); in buf_reader_extend_buf() localVariable
937 assert_eq!(Bufferless.extend_buf_sync(&mut read).unwrap(), 3); in buf_reader_extend_buf()
938 assert_eq!(read.buffer(), [1, 2, 3]); in buf_reader_extend_buf()
940 assert_eq!(Bufferless.extend_buf_sync(&mut read).unwrap(), 7); in buf_reader_extend_buf()
941 assert_eq!(read.buffer(), [1, 2, 3, 4, 5, 6, 7, 8, 9, 0]); in buf_reader_extend_buf()