Trait tokio_buf::util::BufStreamExt

source · [−]
pub trait BufStreamExt: BufStream {
    fn chain<T>(self, other: T) -> Chain<Self, T>
    where
        Self: Sized,
        T: BufStream<Error = Self::Error>,
    { ... }

    fn collect<T>(self) -> Collect<Self, T>
    where
        Self: Sized,
        T: FromBufStream<Self::Item>,
    { ... }

    fn limit(self, amount: u64) -> Limit<Self>
    where
        Self: Sized,
    { ... }

    fn into_stream(self) -> IntoStream<Self>
    where
        Self: Sized,
    { ... }
}
Expand description

An extension trait for BufStream’s that provides a variety of convenient adapters.

Provided methods

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

chain() returns a new BufStream value which will first yield all data from self then all data from other.

In other words, it links two buf streams together, in a chain.

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

collect() returns a future that buffers all data yielded from self into storage of type of T. The future completes once self yield None, returning the buffered data.

The collect future will yield an error if self yields an error or if the collect operation errors. The collect error cases are dependent on the target storage type.

Limit the number of bytes that the stream can yield.

limit() returns a new BufStream value which yields all the data from self while ensuring that at most amount bytes are yielded.

If self can yield greater than amount bytes, the returned stream will yield an error.

Creates a Stream from a BufStream.

This produces a Stream of BufStream::Items.

Implementors