Implement TryFrom to transform various I/O primitives into their mio counterparts (#1158)

* `TryFrom<TcpListener> for mio::net::TcpListener`
* `TryFrom<TcpStream> for mio::net::TcpStream`
* `TryFrom<UdpSocket> for mio::net::UdpSocket`
* `TryFrom<UnixListener> for mio_uds::UnixListener`
* `TryFrom<UnixStream> for mio_uds::UnixStream`

tokio-tcp/src/listener.rs

@@ -2,6 +2,7 @@
 use super::incoming::Incoming;
 use super::TcpStream;
 use mio;
+use std::convert::TryFrom;
 use std::fmt;
 use std::io;
 use std::net::{self, SocketAddr};
@@ -313,6 +314,18 @@ impl TcpListener {
     }
 }
 
+impl TryFrom<TcpListener> for mio::net::TcpListener {
+    type Error = io::Error;
+
+    /// Consumes value, returning the mio I/O object.
+    ///
+    /// See [`tokio_reactor::PollEvented::into_inner`] for more details about
+    /// resource deregistration that happens during the call.
+    fn try_from(value: TcpListener) -> Result<Self, Self::Error> {
+        value.io.into_inner()
+    }
+}
+
 impl fmt::Debug for TcpListener {
     fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
         self.io.get_ref().fmt(f)

tokio-tcp/src/stream.rs

@@ -1,6 +1,7 @@
 use bytes::{Buf, BufMut};
 use iovec::IoVec;
 use mio;
+use std::convert::TryFrom;
 use std::fmt;
 use std::future::Future;
 use std::io;
@@ -709,6 +710,18 @@ impl TcpStream {
     }
 }
 
+impl TryFrom<TcpStream> for mio::net::TcpStream {
+    type Error = io::Error;
+
+    /// Consumes value, returning the mio I/O object.
+    ///
+    /// See [`tokio_reactor::PollEvented::into_inner`] for more details about
+    /// resource deregistration that happens during the call.
+    fn try_from(value: TcpStream) -> Result<Self, Self::Error> {
+        value.io.into_inner()
+    }
+}
+
 // ===== impl Read / Write =====
 
 impl AsyncRead for TcpStream {

tokio-udp/src/socket.rs

@@ -1,6 +1,7 @@
 use super::{RecvDgram, SendDgram};
 use futures::{try_ready, Async, Poll};
 use mio;
+use std::convert::TryFrom;
 use std::fmt;
 use std::io;
 use std::net::{self, Ipv4Addr, Ipv6Addr, SocketAddr};
@@ -418,6 +419,18 @@ impl UdpSocket {
     }
 }
 
+impl TryFrom<UdpSocket> for mio::net::UdpSocket {
+    type Error = io::Error;
+
+    /// Consumes value, returning the mio I/O object.
+    ///
+    /// See [`tokio_reactor::PollEvented::into_inner`] for more details about
+    /// resource deregistration that happens during the call.
+    fn try_from(value: UdpSocket) -> Result<Self, Self::Error> {
+        value.io.into_inner()
+    }
+}
+
 impl fmt::Debug for UdpSocket {
     fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
         self.io.get_ref().fmt(f)

tokio-uds/src/listener.rs

@@ -2,6 +2,7 @@ use crate::{Incoming, UnixStream};
 use futures::{try_ready, Async, Poll};
 use mio::Ready;
 use mio_uds;
+use std::convert::TryFrom;
 use std::fmt;
 use std::io;
 use std::os::unix::io::{AsRawFd, RawFd};
@@ -130,6 +131,18 @@ impl UnixListener {
     }
 }
 
+impl TryFrom<UnixListener> for mio_uds::UnixListener {
+    type Error = io::Error;
+
+    /// Consumes value, returning the mio I/O object.
+    ///
+    /// See [`tokio_reactor::PollEvented::into_inner`] for more details about
+    /// resource deregistration that happens during the call.
+    fn try_from(value: UnixListener) -> Result<Self, Self::Error> {
+        value.io.into_inner()
+    }
+}
+
 impl fmt::Debug for UnixListener {
     fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
         self.io.get_ref().fmt(f)

tokio-uds/src/stream.rs

@@ -5,6 +5,7 @@ use iovec::{self, IoVec};
 use libc;
 use mio::Ready;
 use mio_uds;
+use std::convert::TryFrom;
 use std::fmt;
 use std::io::{self, Read, Write};
 use std::net::Shutdown;
@@ -127,6 +128,18 @@ impl UnixStream {
     }
 }
 
+impl TryFrom<UnixStream> for mio_uds::UnixStream {
+    type Error = io::Error;
+
+    /// Consumes value, returning the mio I/O object.
+    ///
+    /// See [`tokio_reactor::PollEvented::into_inner`] for more details about
+    /// resource deregistration that happens during the call.
+    fn try_from(value: UnixStream) -> Result<Self, Self::Error> {
+        value.io.into_inner()
+    }
+}
+
 impl Read for UnixStream {
     fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> {
         self.io.read(buf)