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 From for Transport { + 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(addr: &SocketAddr) -> io::Result> where