Struct IncomingStream

pub struct IncomingStream<'a, L>
where
    L: Listener,
{ /* private fields */ }

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

An incoming stream.

Used with serve and IntoMakeServiceWithConnectInfo.

Implementations

impl<L> IncomingStream<'_, L>

where L: Listener,

pub fn io(&self) -> &L::Io

Get a reference to the inner IO type.

pub fn remote_addr(&self) -> &L::Addr

Returns the remote address that this stream is bound to.

Trait Implementations

impl Connected<IncomingStream<'_, TcpListener>> for SocketAddr

fn connect_info(stream: IncomingStream<'_, TcpListener>) -> Self

Create type holding information about the connection.

impl<'a, L, F> Connected<IncomingStream<'a, TapIo<L, F>>> for L::Addr

where L: Listener, L::Addr: Clone + Sync + 'static, F: FnMut(&mut L::Io) + Send + 'static,

fn connect_info(stream: IncomingStream<'a, TapIo<L, F>>) -> Self

Create type holding information about the connection.

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

where L: Listener + Debug, L::Io: Debug, L::Addr: Debug,

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

Formats the value using the given formatter.

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

where H: Clone, S: Clone, L: Listener,

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<'_, L>>>::Response, <HandlerService<H, T, S> as Service<IncomingStream<'_, L>>>::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<'_, L>) -> Self::Future

Process the request and return the response asynchronously.

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

where L: Listener,

type Response = MethodRouter

Responses given by the service.

type Error = Infallible

Errors produced by the service.

type Future = Ready<Result<<MethodRouter as Service<IncomingStream<'_, L>>>::Response, <MethodRouter as Service<IncomingStream<'_, L>>>::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<'_, L>) -> Self::Future

Process the request and return the response asynchronously.

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

where L: Listener,

type Response = Router

Responses given by the service.

type Error = Infallible

Errors produced by the service.

type Future = Ready<Result<<Router as Service<IncomingStream<'_, L>>>::Response, <Router as Service<IncomingStream<'_, L>>>::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<'_, L>) -> Self::Future

Process the request and return the response asynchronously.