Struct replacing_buf_stream::ReplacingBufStream

pub struct ReplacingBufStream<Stream: BufStream<Item = Cursor<Bytes>>> { /* fields omitted */ }

Methods

impl<Stream: BufStream<Item = Cursor<Bytes>>> ReplacingBufStream<Stream>

pub fn new(
    inner: Stream,
    to_be_replaced: Bytes,
    replacement: Bytes
) -> ReplacingBufStream<Stream>

Trait Implementations

impl<Stream: BufStream<Item = Cursor<Bytes>>> BufStream for ReplacingBufStream<Stream> where
    <Stream as BufStream>::Error: Debug, 

type Item = Cursor<Bytes>

Values yielded by the BufStream.

type Error = Stream::Error

The error type this BufStream might generate.

fn poll(&mut self) -> Poll<Option<Self::Item>, Self::Error>

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

fn size_hint(&self) -> SizeHint

Returns the bounds on the remaining length of the iterator.

fn chain<T>(self, other: T) -> Chain<Self, T> where
    T: BufStream<Error = Self::Error>, 

Takes two buf streams and creates a new buf stream over both in sequence.

fn collect<T>(self) -> Collect<Self, T> where
    T: FromBufStream, 

Consumes all data from self, storing it in byte storage of type T.