fn on_request()

in hfendpoints-core/src/handler.rs [105:118]


    fn on_request(
        &self,
        request: Self::Request,
    ) -> impl Future<Output = Result<Self::Response, Error>> + Send;
}

pub async fn wait_for_requests<I, O, H>(
    mut ingress: UnboundedReceiver<(I, UnboundedSender<Result<O, Error>>)>,
    background_handler: Arc<H>,
) where
    I: Send + 'static,
    O: Send + 'static,
    H: Handler<Request = I, Response = O> + Send + Sync + 'static,
{