WIP

quinn/src/runtime/async_io.rs

@@ -1,4 +1,3 @@
-use async_io::{Async, Timer};
 use std::{
     future::Future,
     io,
@@ -8,6 +7,7 @@ use std::{
     time::Instant,
 };
 
+use async_io::{Async, Timer};
 use super::{AsyncTimer, AsyncUdpSocket, Runtime};
 
 #[cfg(feature = "smol")]
@@ -33,7 +33,7 @@ mod smol {
             &self,
             sock: std::net::UdpSocket,
         ) -> io::Result<Arc<dyn AsyncUdpSocket>> {
-            Ok(Arc::new(AsyncIOUdpSocket::new(sock)?))
+            Ok(Arc::new(UdpSocket::new(sock)?))
         }
     }
 }
@@ -61,7 +61,7 @@ mod async_std {
             &self,
             sock: std::net::UdpSocket,
         ) -> io::Result<Arc<dyn AsyncUdpSocket>> {
-            Ok(Arc::new(AsyncIOUdpSocket::new(sock)?))
+            Ok(Arc::new(UdpSocket::new(sock)?))
         }
     }
 }
@@ -77,12 +77,12 @@ impl AsyncTimer for Timer {
 }
 
 #[derive(Debug)]
-struct AsyncIOUdpSocket {
+struct UdpSocket {
     io: Async<std::net::UdpSocket>,
     inner: udp::UdpSocketState,
 }
 
-impl AsyncIOUdpSocket {
+impl UdpSocket {
     fn new(sock: std::net::UdpSocket) -> io::Result<Self> {
         Ok(Self {
             inner: udp::UdpSocketState::new((&sock).into())?,
@@ -91,7 +91,7 @@ impl AsyncIOUdpSocket {
     }
 }
 
-impl AsyncUdpSocket for AsyncIOUdpSocket {
+impl AsyncUdpSocket for UdpSocket {
     fn poll_send(&self, cx: &mut Context, transmits: &[udp::Transmit]) -> Poll<io::Result<usize>> {
         loop {
             ready!(self.io.poll_writable(cx))?;