Struct RequestExt

pub struct RequestExt<B> { /* private fields */ }

extension types for Request

Implementations

impl<B> RequestExt<B>

pub fn socket_addr(&self) -> &SocketAddr

retrieve remote peer’s socket address.

Default

std::net::Ipv4Addr::UNSPECIFIED is used for representing peers that can’t provide it’s socket address.

pub fn socket_addr_mut(&mut self) -> &mut SocketAddr

exclusive version of RequestExt::socket_addr

pub fn map_body<F, B1>(self, func: F) -> RequestExt<B1>

where F: FnOnce(B) -> B1,

map body type of self to another type with given function closure.

pub fn replace_body<B1>(self, body: B1) -> (RequestExt<B1>, B)

replace body type of self with another type and return new type of Self and original body type in tuple.

Trait Implementations

impl<B> Borrow<SocketAddr> for RequestExt<B>

fn borrow(&self) -> &SocketAddr

Immutably borrows from an owned value.

impl<B> Clone for RequestExt<B>

where B: Clone,

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<B: Debug> Debug for RequestExt<B>

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

Formats the value using the given formatter.

impl<B> Default for RequestExt<B>

where B: Default,

fn default() -> Self

Returns the “default value” for a type.

impl<B> Stream for RequestExt<B>

where B: Stream,

type Item = <B as Stream>::Item

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value 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) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.

impl<'__pin, B> Unpin for RequestExt<B>

where PinnedFieldsOf<__Origin<'__pin, B>>: Unpin,