Trait streamparser::AdvanceAsync

pub trait AdvanceAsync {
    type Error;
    fn poll_advance(
        self: Pin<&mut Self>, 
        cx: &mut Context
    ) -> Poll<Result<(), Self::Error>>;
}

Associated Types

type Error

Loading content...

Required methods

fn poll_advance(
    self: Pin<&mut Self>,
    cx: &mut Context
) -> Poll<Result<(), Self::Error>>

Loading content...

Implementors

impl<B, E, T, S> AdvanceAsync for IterSource<T, S> where
    T: Clone + Unpin,
    B: AsRef<[T]>,
    S: Stream<Item = Result<B, E>> + Unpin, 

type Error = E

fn poll_advance(
    self: Pin<&mut Self>,
    cx: &mut Context
) -> Poll<Result<(), Self::Error>>

impl<S> AdvanceAsync for ReadSource<u8, S> where
    S: AsyncRead + Unpin, 

type Error = S::Error

fn poll_advance(
    self: Pin<&mut Self>,
    cx: &mut Context
) -> Poll<Result<(), Self::Error>>

Loading content...