1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
use crate::{BufList, Cursor};
use futures_io_03::{AsyncBufRead, AsyncRead, AsyncSeek};
use std::{
io::{self, IoSliceMut, SeekFrom},
pin::Pin,
task::{Context, Poll},
};
impl<T: AsRef<BufList> + Unpin> AsyncSeek for Cursor<T> {
fn poll_seek(
mut self: Pin<&mut Self>,
_: &mut Context<'_>,
pos: SeekFrom,
) -> Poll<io::Result<u64>> {
Poll::Ready(io::Seek::seek(&mut *self, pos))
}
}
impl<T: AsRef<BufList> + Unpin> AsyncRead for Cursor<T> {
fn poll_read(
mut self: Pin<&mut Self>,
_cx: &mut Context<'_>,
buf: &mut [u8],
) -> Poll<io::Result<usize>> {
Poll::Ready(io::Read::read(&mut *self, buf))
}
fn poll_read_vectored(
mut self: Pin<&mut Self>,
_: &mut Context<'_>,
bufs: &mut [IoSliceMut<'_>],
) -> Poll<io::Result<usize>> {
Poll::Ready(io::Read::read_vectored(&mut *self, bufs))
}
}
impl<T: AsRef<BufList> + Unpin> AsyncBufRead for Cursor<T> {
fn poll_fill_buf(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<io::Result<&[u8]>> {
Poll::Ready(io::BufRead::fill_buf(self.get_mut()))
}
fn consume(mut self: Pin<&mut Self>, amt: usize) {
io::BufRead::consume(&mut *self, amt)
}
}