Struct bitar::archive_reader::IoReader

pub struct IoReader<T>(/* private fields */);

Wrapper which implements ArchiveReader for any type which implements tokio AsyncRead and AsyncSeek.

Implementations

impl<T> IoReader<T>

pub fn new(inner: T) -> Self

Trait Implementations

impl<T> ArchiveReader for IoReader<T>

where T: AsyncRead + AsyncSeek + Unpin + Send,

type Error = Error

fn read_at<'life0, 'async_trait>( &'life0 mut self, offset: u64, size: usize ) -> Pin<Box<dyn Future<Output = Result<Bytes, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Read a single chunk from archive.

fn read_chunks<'a>( &'a mut self, chunks: Vec<ChunkOffset> ) -> Pin<Box<dyn Stream<Item = Result<Bytes, Error>> + Send + 'a>>

Read multiple chunks from archive. Returns a stream of the requested chunks.

impl<T> From<T> for IoReader<T>

fn from(inner: T) -> Self

Converts to this type from the input type.