Wake up connection when dropping SendRequest (#538)

Fixes #502
This commit is contained in:
Anthony Ramine
2021-05-06 20:57:44 +02:00
committed by GitHub
parent fea3ae6ca9
commit 47d107aa17

View File

@@ -990,7 +990,14 @@ where
P: Peer,
{
fn drop(&mut self) {
let _ = self.inner.lock().map(|mut inner| inner.refs -= 1);
if let Ok(mut inner) = self.inner.lock() {
inner.refs -= 1;
if inner.refs == 1 {
if let Some(task) = inner.actions.task.take() {
task.wake();
}
}
}
}
}