Trait tower_web::util::BufStream

pub trait BufStream {
    type Item: Buf;
    type Error;
    fn poll(&mut self) -> Poll<Option<Self::Item>, Self::Error>;

    fn size_hint(&self) -> SizeHint { ... }
    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,
    { ... }
}

An asynchronous stream of bytes.

BufStream asynchronously yields values implementing Buf, i.e. byte buffers.

Associated Types

type Item: Buf

Values yielded by the BufStream.

type Error

The error type this BufStream might generate.

Loading content...

Required methods

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.

Return value

There are several possible return values, each indicating a distinct stream state:

• Ok(Async::NotReady) means that this stream's next value is not ready yet. Implementations will ensure that the current task will be notified when the next value may be ready.

• Ok(Async::Ready(Some(buf))) means that the stream has successfully produced a value, buf, and may produce further values on subsequent poll calls.

• Ok(Async::Ready(None)) means that the stream has terminated, and poll should not be invoked again.

Panics

Once a stream is finished, i.e. Ready(None) has been returned, further calls to poll may result in a panic or other "bad behavior".

Loading content...

Provided methods

fn size_hint(&self) -> SizeHint

Returns the bounds on the remaining length of the iterator.

Implementation notes

It is not enforced that a BufStreaam yields the declared amount of data. A buggy implementation may yield less than the lower bound or more than the upper bound.

size_hint() is primarily intended to be used for optimizations such as reserving space for the data, but must not be trusted to e.g. omit bounds checks in unsafe code. An incorrect implemeentation of size_hint() should not lead to memory safety violations.

That said, the implementation should provide a correct estimation, because otherwise it would be a violation of the trait's protocol.

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

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

chain() will return 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.

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

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

Loading content...

Implementations on Foreign Types

impl<B> BufStream for Option<B> where
    B: BufStream, 

type Item = B::Item

type Error = B::Error

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

fn size_hint(&self) -> SizeHint

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, 

impl BufStream for Bytes

type Item = Cursor<Bytes>

type Error = ()

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

fn size_hint(&self) -> SizeHint

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, 

impl<A, B> BufStream for Either<A, B> where
    A: BufStream,
    B: BufStream<Item = A::Item, Error = A::Error>, 

type Item = A::Item

type Error = A::Error

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

fn size_hint(&self) -> SizeHint

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, 

impl BufStream for File

type Item = Cursor<BytesMut>

type Error = Error

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

fn size_hint(&self) -> SizeHint

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, 

impl BufStream for String

type Item = Cursor<Vec<u8>>

type Error = Never

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

fn size_hint(&self) -> SizeHint

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, 

impl BufStream for &'static str

type Item = Cursor<&'static [u8]>

type Error = Never

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

fn size_hint(&self) -> SizeHint

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, 

impl BufStream for Body

type Item = Chunk

type Error = Error

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

fn size_hint(&self) -> SizeHint

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, 

Loading content...

Implementors

impl<Item, Error> BufStream for Empty<Item, Error> where
    Item: Buf, 

type Item = Item

type Error = Error

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

fn size_hint(&self) -> SizeHint

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, 

impl<T> BufStream for CompressStream<T> where
    T: BufStream, 

type Item = Cursor<Bytes>

type Error = Error<T::Error>

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

fn size_hint(&self) -> SizeHint

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, 

impl<T> BufStream for StdStream<T> where
    T: Stream,
    T::Item: Buf, 

type Item = T::Item

type Error = T::Error

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

fn size_hint(&self) -> SizeHint

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, 

impl<T, U> BufStream for Chain<T, U> where
    T: BufStream,
    U: BufStream<Error = T::Error>, 

type Item = Either<T::Item, U::Item>

type Error = T::Error

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

fn size_hint(&self) -> SizeHint

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, 

impl<T: BufStream> BufStream for Map<T>

type Item = T::Item

type Error = Error

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

fn size_hint(&self) -> SizeHint

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, 

Loading content...