pub struct IntoBufStream<T> { /* private fields */ }Expand description
Wraps a Body instance, implementing tokio_buf::BufStream.
See into_buf_stream function documentation for more details.
Trait Implementations§
Source§impl<T> BufStream for IntoBufStream<T>where
T: Body,
impl<T> BufStream for IntoBufStream<T>where
T: Body,
Auto Trait Implementations§
impl<T> Freeze for IntoBufStream<T>where
T: Freeze,
impl<T> RefUnwindSafe for IntoBufStream<T>where
T: RefUnwindSafe,
impl<T> Send for IntoBufStream<T>where
T: Send,
impl<T> Sync for IntoBufStream<T>where
T: Sync,
impl<T> Unpin for IntoBufStream<T>where
T: Unpin,
impl<T> UnwindSafe for IntoBufStream<T>where
T: UnwindSafe,
Blanket Implementations§
Source§impl<T> Body for Twhere
T: BufStream,
impl<T> Body for Twhere
T: BufStream,
Source§fn poll_data(
&mut self,
) -> Result<Async<Option<<T as Body>::Data>>, <T as Body>::Error>
fn poll_data( &mut self, ) -> Result<Async<Option<<T as Body>::Data>>, <T as Body>::Error>
Attempt to pull out the next data buffer of this stream.
Source§fn size_hint(&self) -> SizeHint
fn size_hint(&self) -> SizeHint
Returns the bounds on the remaining length of the stream. Read more
Source§fn poll_trailers(
&mut self,
) -> Result<Async<Option<HeaderMap>>, <T as Body>::Error>
fn poll_trailers( &mut self, ) -> Result<Async<Option<HeaderMap>>, <T as Body>::Error>
Poll for an optional single
HeaderMap of trailers. Read moreSource§fn is_end_stream(&self) -> bool
fn is_end_stream(&self) -> bool
Returns
true when the end of stream has been reached. Read moreSource§impl<T> BodyExt for Twhere
T: Body,
impl<T> BodyExt for Twhere
T: Body,
Source§fn into_buf_stream(self) -> IntoBufStream<Self>where
Self: Sized,
fn into_buf_stream(self) -> IntoBufStream<Self>where
Self: Sized,
Wrap the
Body so that it implements tokio_buf::BufStream directly.Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> BufStreamExt for Twhere
T: BufStream,
impl<T> BufStreamExt for Twhere
T: BufStream,
Source§fn chain<T>(self, other: T) -> Chain<Self, T>
fn chain<T>(self, other: T) -> Chain<Self, T>
Takes two buf streams and creates a new buf stream over both in
sequence. Read more
Source§fn limit(self, amount: u64) -> Limit<Self>where
Self: Sized,
fn limit(self, amount: u64) -> Limit<Self>where
Self: Sized,
Limit the number of bytes that the stream can yield. Read more
Source§fn into_stream(self) -> IntoStream<Self>where
Self: Sized,
fn into_stream(self) -> IntoStream<Self>where
Self: Sized,
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more