diff --git a/src/main.rs b/src/main.rs index 18b7c48..a2d933a 100644 --- a/src/main.rs +++ b/src/main.rs @@ -315,7 +315,7 @@ async fn do_server_main( .wrap(config.digest_middleware().spawner(verify_spawner.clone())) .wrap(VerifySignature::new( MyVerify( - requests, + requests.spawner(verify_spawner.clone()), actors.clone(), state.clone(), verify_spawner.clone(), diff --git a/src/requests.rs b/src/requests.rs index f1cd1bc..ee88272 100644 --- a/src/requests.rs +++ b/src/requests.rs @@ -208,6 +208,11 @@ impl Requests { } } + pub(crate) fn spawner(mut self, spawner: Spawner) -> Self { + self.config = self.config.spawner(spawner); + self + } + pub(crate) fn reset_breaker(&self, iri: &IriString) { self.breakers.succeed(iri); }