Trait StreamLayeredExt 

pub trait StreamLayeredExt: Stream<Item = Bytes> {
    // Required method
    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

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]

Implementors

impl<T> StreamLayeredExt for T

where T: Stream<Item = Bytes>,