Struct TowerService 

pub struct TowerService<A> { /* private fields */ }

Available on crate feature tower only.

An rws Application as a Tower Service<http::Request<B>> — to serve it with hyper, or nest it in an axum Router (Router::fallback_service).

The request body is read into memory first. The app runs as rws runs it: execute_async when it offers one, inline when it says so, otherwise on the blocking pool — so call it from inside a tokio runtime. An app error becomes a 500; the service itself never fails. ConnectionInfo is TowerService::connection’s (default: unknown peer, port 0), since Tower carries no peer address of its own.

Implementations

impl<A> TowerService<A>

pub fn new(app: A) -> TowerService<A>

pub fn connection(self, connection: ConnectionInfo) -> TowerService<A>

What handlers see as the connection.

Trait Implementations

impl<A> Clone for TowerService<A>

fn clone(&self) -> TowerService<A>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<A, B> Service<Request<B>> for TowerService<A>

where A: Application + Send + Sync + 'static, B: Body<Data = Bytes> + Send + 'static, <B as Body>::Error: Into<Box<dyn Error + Send + Sync>>,

type Response = Response<Body>

Responses given by the service.

type Error = !

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<Response<Body>, !>> + Send>>

The future response value.

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

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

fn call( &mut self, request: Request<B>, ) -> <TowerService<A> as Service<Request<B>>>::Future

Process the request and return the response asynchronously.