Struct `Incoming`

#[must_use = "streams do nothing unless polled"]
pub struct Incoming { /* private fields */ }

A stream of Bytes, used when receiving bodies from the network.

Note that Users should not instantiate this struct directly. When working with the hyper client, Incoming is returned to you in responses. Similarly, when operating with the hyper server, it is provided within requests.

Examples

async fn echo(
   req: Request<hyper::body::Incoming>,
) -> Result<Response<BoxBody<Bytes, hyper::Error>>, hyper::Error> {
   //Here, you can process `Incoming`
}

Trait Implementations

`impl Body for Incoming`

type Data = Bytes;
type Error = Error;
fn poll_frame(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Result<Frame<Self::Data>, Self::Error>>>
fn is_end_stream(&self) -> bool
fn size_hint(&self) -> SizeHint

`impl Debug for Incoming`

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Auto Trait Implementations

`impl !RefUnwindSafe for Incoming`

`impl !UnwindSafe for Incoming`

`impl Freeze for Incoming`

`impl Send for Incoming`

`impl Sync for Incoming`

`impl Unpin for Incoming`

`impl UnsafeUnpin for Incoming`

Blanket Implementations

`impl<T> Any for Incoming where T: 'static + ?Sized,`

fn type_id(&self) -> TypeId

`impl<T> Borrow<T> for Incoming where T: ?Sized,`

fn borrow(&self) -> &T

`impl<T> BorrowMut<T> for Incoming where T: ?Sized,`

fn borrow_mut(&mut self) -> &mut T

`impl<T> From<T> for Incoming`

fn from(t: T) -> T: Returns the argument unchanged.

`impl<T> Instrument for Incoming`

`impl<T> WithSubscriber for Incoming`

`impl<T, U> Into<U> for Incoming where U: From<T>,`

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of [From]<T> for U chooses to do.

`impl<T, U> TryFrom<U> for Incoming where U: Into<T>,`

type Error = never;
fn try_from(value: U) -> Result<T, never>

`impl<T, U> TryInto<U> for Incoming where U: TryFrom<T>,`

type Error = <U as TryFrom<T>>::Error;
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>