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,
{