Struct catalyzer::internals::crates::axum::serve::IncomingStream

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

An incoming stream.

Used with serve and IntoMakeServiceWithConnectInfo.

Implementations

impl IncomingStream<'_>

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

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<'_>) -> SocketAddr

Create type holding information about the connection.

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

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

Formats the value using the given formatter.

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<(), <Router as Service<IncomingStream<'_>>>::Error>>

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

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

Process the request and return the response asynchronously.

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<(), <HandlerService<H, T, S> as Service<IncomingStream<'_>>>::Error>>

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

fn call( &mut self, _req: IncomingStream<'_> ) -> <HandlerService<H, T, S> as Service<IncomingStream<'_>>>::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<(), <MethodRouter as Service<IncomingStream<'_>>>::Error>>

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

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

Process the request and return the response asynchronously.