Use verify spawner in all cases in verify path
This commit is contained in:
parent
f06316c6b2
commit
7438b0c5d0
@ -315,7 +315,7 @@ async fn do_server_main(
|
|||||||
.wrap(config.digest_middleware().spawner(verify_spawner.clone()))
|
.wrap(config.digest_middleware().spawner(verify_spawner.clone()))
|
||||||
.wrap(VerifySignature::new(
|
.wrap(VerifySignature::new(
|
||||||
MyVerify(
|
MyVerify(
|
||||||
requests,
|
requests.spawner(verify_spawner.clone()),
|
||||||
actors.clone(),
|
actors.clone(),
|
||||||
state.clone(),
|
state.clone(),
|
||||||
verify_spawner.clone(),
|
verify_spawner.clone(),
|
||||||
|
@ -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) {
|
pub(crate) fn reset_breaker(&self, iri: &IriString) {
|
||||||
self.breakers.succeed(iri);
|
self.breakers.succeed(iri);
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user