Register transport in pt reactor even if it has no pending requests

This commit is contained in:
Nick Mathewson 2022-11-29 19:35:38 -05:00
parent 9765fdc2e6
commit fdc49b1fed
1 changed files with 1 additions and 1 deletions

View File

@ -164,9 +164,9 @@ impl<R: Runtime> PtReactor<R> {
Ok(pt) => {
let mut state = self.state.write().expect("ptmgr state poisoned");
for (transport, method) in pt.transport_methods() {
state.cmethods.insert(transport.clone(), method.clone());
for sender in self.requests.remove(transport).into_iter().flatten() {
let _ = sender.send(Ok(method.clone()));
state.cmethods.insert(transport.clone(), method.clone());
}
}
}