in chrony-candm/src/async_net.rs [196:208]
fn poll(
self: std::pin::Pin<&mut Self>,
cx: &mut std::task::Context<'_>,
) -> std::task::Poll<Self::Output> {
let receiver = &mut self.get_mut().0;
let mut result = receiver.unwrap_or_else(|e| {
Err(std::io::Error::new(
std::io::ErrorKind::ConnectionAborted,
e,
))
});
Pin::new(&mut result).poll(cx)
}