Struct tari_service_framework::LazyService

#[must_use = "futures do nothing unless you `.await` or poll them"]pub struct LazyService<TFn, F, S> { /* fields omitted */ }

LazyService

Implements the tower_service::Service trait. The poll_ready function will poll the given future. Once that future is ready, the resulting value is passed into the given service_fn function which must return a service. Subsequent calls to poll_ready and call are delegated to that service.

This is instantiated by the lazy_service combinator in ServiceHandlesFuture.

Implementations

impl<TFn, F, S> LazyService<TFn, F, S>

pub fn new(future: F, service_fn: TFn) -> Self

Create a new LazyService

Trait Implementations

impl<TFn, F, S, TReq> Service<TReq> for LazyService<TFn, F, S> where
    F: Future + Unpin,
    TFn: FnOnce(F::Output) -> S,
    S: Service<TReq>, 

type Error = S::Error

Errors produced by the service.

type Future = S::Future

The future response value.

type Response = S::Response

Responses given by the service.

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: TReq) -> Self::Future

Process the request and return the response asynchronously.