Trait SeekableStream

Source

pub trait SeekableStream:
    AsyncRead
    + Unpin
    + Debug
    + Send
    + Sync
    + DynClone {
    // Required methods
    fn reset<'life0, 'async_trait>(
        &'life0 mut self,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
       where 'life0: 'async_trait,
             Self: 'async_trait;
    fn len(&self) -> usize;

    // Provided methods
    fn is_empty(&self) -> bool { ... }
    fn buffer_size(&self) -> usize { ... }
}

Expand description

Enable a type implementing AsyncRead to be consumed as if it were a Stream of Bytes.

Required Methods§

Source

fn reset<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, Self: 'async_trait,

Source

fn len(&self) -> usize

Provided Methods§

Source

fn is_empty(&self) -> bool

Source

fn buffer_size(&self) -> usize

Trait Implementations§

Source §

impl Stream for dyn SeekableStream

Source §

type Item = Result<Bytes, Error>

Values yielded by the stream.

Source §

fn poll_next( self: Pin<&mut (dyn SeekableStream + 'static)>, cx: &mut Context<'_>, ) -> Poll<Option<<dyn SeekableStream as Stream>::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted. Read more

Source §