Struct axum::serve::IncomingStream

pub struct IncomingStream<'a> { /* private fields */ }

Available on crate feature tokio and (crate features http1 or http2) only.

An incoming stream.

Used with serve and IntoMakeServiceWithConnectInfo.

Implementations

impl IncomingStream<'_>

pub fn local_addr(&self) -> Result<SocketAddr>

Returns the local address that this stream is bound to.

pub fn remote_addr(&self) -> SocketAddr

Returns the remote address that this stream is bound to.

Trait Implementations

impl Connected<IncomingStream<'_>> for SocketAddr

fn connect_info(target: IncomingStream<'_>) -> Self

Create type holding information about the connection.

impl<'a> Debug for IncomingStream<'a>

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

Formats the value using the given formatter.

impl<H, T, S> Service<IncomingStream<'_>> for HandlerService<H, T, S>

where H: Clone, S: Clone,

type Response = HandlerService<H, T, S>

Responses given by the service.

type Error = Infallible

Errors produced by the service.

type Future = Ready<Result<<HandlerService<H, T, S> as Service<IncomingStream<'_>>>::Response, <HandlerService<H, T, S> as Service<IncomingStream<'_>>>::Error>>

The future response value.

fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, _req: IncomingStream<'_>) -> Self::Future

Process the request and return the response asynchronously.

impl Service<IncomingStream<'_>> for MethodRouter<()>

type Response = MethodRouter

Responses given by the service.

type Error = Infallible

Errors produced by the service.

type Future = Ready<Result<<MethodRouter as Service<IncomingStream<'_>>>::Response, <MethodRouter as Service<IncomingStream<'_>>>::Error>>

The future response value.

fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, _req: IncomingStream<'_>) -> Self::Future

Process the request and return the response asynchronously.

impl Service<IncomingStream<'_>> for Router<()>

type Response = Router

Responses given by the service.

type Error = Infallible

Errors produced by the service.

type Future = Ready<Result<<Router as Service<IncomingStream<'_>>>::Response, <Router as Service<IncomingStream<'_>>>::Error>>

The future response value.

fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, _req: IncomingStream<'_>) -> Self::Future

Process the request and return the response asynchronously.