This commit is contained in:
Ferdinand Schober
2024-07-14 14:36:36 +02:00
parent a7e7941806
commit 4bac6d4bae

View File

@@ -203,13 +203,13 @@ impl Server {
}
},
_ = self.notifies.dns_request_pending.notified() => {
let requests = self
.pending_dns_requests
.borrow_mut()
.drain(..)
.collect::<Vec<_>>();
for request in requests {
dns_request.send(request).await.expect("channel closed");
loop {
let request = self.pending_dns_requests.borrow_mut().pop_front();
if let Some(request) = request {
dns_request.send(request).await.expect("channel closed");
} else {
break;
}
}
}
_ = self.cancelled() => break,