Trait streamcatcher::future::AsyncTransform

pub trait AsyncTransform<TInput: AsyncRead> {
    fn transform_poll_read(
        &mut self, 
        src: Pin<&mut TInput>, 
        cx: &mut Context<'_>, 
        buf: &mut [u8]
    ) -> Poll<IoResult<TransformPosition>>;

    fn min_bytes_required(&self) -> usize { ... }
}

Async variant of Transform.

Required methods

fn transform_poll_read(
    &mut self,
    src: Pin<&mut TInput>,
    cx: &mut Context<'_>,
    buf: &mut [u8]
) -> Poll<IoResult<TransformPosition>>

Loading content...

Provided methods

fn min_bytes_required(&self) -> usize

Loading content...

Implementors

impl<T: AsyncRead> AsyncTransform<T> for Identity

fn transform_poll_read(
    &mut self,
    src: Pin<&mut T>,
    cx: &mut Context<'_>,
    buf: &mut [u8]
) -> Poll<IoResult<TransformPosition>>

Loading content...