From 8847330dbeb514ab594e2dae0943c9cff6e5cd03 Mon Sep 17 00:00:00 2001
From: Tim Kuehn <tikue@google.com>
Date: Thu, 18 Oct 2018 00:24:08 -0700
Subject: [PATCH] impl From<S> for bincode::Transport<S>

---
 bincode-transport/src/lib.rs | 12 +++++++++---
 1 file changed, 9 insertions(+), 3 deletions(-)

diff --git a/bincode-transport/src/lib.rs b/bincode-transport/src/lib.rs
index 48348a7..17b467d 100644
--- a/bincode-transport/src/lib.rs
+++ b/bincode-transport/src/lib.rs
@@ -118,12 +118,18 @@ where
     Item: for<'de> Deserialize<'de>,
     SinkItem: Serialize,
 {
-    Transport {
-        inner: Compat::new(AsyncBincodeStream::from(io).for_async()),
-    }
+    Transport::from(io)
 
 }
 
+impl<S, Item, SinkItem> From<S> for Transport<S, Item, SinkItem> {
+    fn from(inner: S) -> Self {
+        Transport {
+            inner: Compat::new(AsyncBincodeStream::from(inner).for_async()),
+        }
+    }
+}
+
 /// Connects to `addr`, wrapping the connection in a bincode transport.
 pub async fn connect<Item, SinkItem>(addr: &SocketAddr) -> io::Result<Transport<TcpStream, Item, SinkItem>>
 where