Trait futures_ext::StreamLayeredExt

pub trait StreamLayeredExt: Stream<Item = Bytes> {
    pub fn decode<Dec>(self, decoder: Dec) -> LayeredDecode<Self, Dec>
    where
        Self: Sized,
        Dec: Decoder;
}

Trait that provides a function for making a decoding layer on top of Stream of Bytes

Required methods

pub fn decode<Dec>(self, decoder: Dec) -> LayeredDecode<Self, Dec> where
    Self: Sized,
    Dec: Decoder, 

Returnes a Stream that will yield decoded chunks of Bytes as they come using provided Decoder

Loading content...

Implementors

impl<T> StreamLayeredExt for T where
    T: Stream<Item = Bytes>, 

pub fn decode<Dec>(self, decoder: Dec) -> LayeredDecode<Self, Dec> where
    Self: Sized,
    Dec: Decoder, 

Loading content...