romio alpha.5

Signed-off-by: Yoshua Wuyts <[email protected]>

Author: yoshuawuyts

runtime-native/Cargo.toml

@@ -16,6 +16,6 @@ edition = "2018"
 async-datagram = "2.0.0"
 futures-preview = "0.3.0-alpha.13"
 lazy_static = "1.0.0"
-romio = "0.3.0-alpha.4"
+romio = "0.3.0-alpha.5"
 runtime-raw = { path = "../runtime-raw", version = "0.3.0-alpha.1" }
 juliex = "0.3.0-alpha.3"

runtime-native/src/tcp.rs

@@ -1,5 +1,5 @@
 use futures::prelude::*;
-use romio::async_ready::{AsyncReadReady, AsyncReady, AsyncWriteReady};
+use romio::raw::{AsyncReadReady, AsyncReady, AsyncWriteReady};
 
 use std::io;
 use std::net::SocketAddr;
@@ -18,11 +18,15 @@ pub(crate) struct TcpListener {
 
 impl runtime_raw::TcpStream for TcpStream {
     fn poll_write_ready(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> {
-        Pin::new(&mut self.romio_stream).poll_write_ready(cx).map_ok(|_| ())
+        Pin::new(&mut self.romio_stream)
+            .poll_write_ready(cx)
+            .map_ok(|_| ())
     }
 
     fn poll_read_ready(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> {
-        Pin::new(&mut self.romio_stream).poll_read_ready(cx).map_ok(|_| ())
+        Pin::new(&mut self.romio_stream)
+            .poll_read_ready(cx)
+            .map_ok(|_| ())
     }
 
     fn take_error(&self) -> io::Result<Option<io::Error>> {