Struct IncomingStream

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

An incoming stream.

Used with serve and IntoMakeServiceWithConnectInfo.

Implementations

impl<L> IncomingStream<'_, L>

where L: Listener,

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

Get a reference to the inner IO type.

pub fn remote_addr(&self) -> &<L as Listener>::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>) -> SocketAddr

Create type holding information about the connection.

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

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

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

Create type holding information about the connection.

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

where L: Debug + Listener, <L as Listener>::Io: Debug, <L as Listener>::Addr: Debug,

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

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

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

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

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

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

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

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

Process the request and return the response asynchronously.