From c6c2bfa45601df7ead1a17778d3fc59e15eb3b8c Mon Sep 17 00:00:00 2001
From: Mark Hildreth <mark.k.hildreth@gmail.com>
Date: Thu, 31 Oct 2019 11:05:44 -0400
Subject: [PATCH] Added TCP smoke tests against std Listener and Stream

---
 tests/tcp.rs | 45 +++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 45 insertions(+)

diff --git a/tests/tcp.rs b/tests/tcp.rs
index c8281d71..00fa3a04 100644
--- a/tests/tcp.rs
+++ b/tests/tcp.rs
@@ -49,3 +49,48 @@ fn incoming_read() -> io::Result<()> {
         Ok(())
     })
 }
+
+#[test]
+fn smoke_std_stream_to_async_listener() -> io::Result<()> {
+    use std::io::Write;
+
+    task::block_on(async {
+        let listener = TcpListener::bind("127.0.0.1:0").await?;
+        let addr = listener.local_addr()?;
+
+        let mut std_stream = std::net::TcpStream::connect(&addr)?;
+        std_stream.write_all(THE_WINTERS_TALE)?;
+
+        let mut buf = vec![0; 1024];
+        let mut incoming = listener.incoming();
+        let mut stream = incoming.next().await.unwrap()?;
+
+        let n = stream.read(&mut buf).await?;
+        assert_eq!(&buf[..n], THE_WINTERS_TALE);
+
+        Ok(())
+    })
+}
+
+#[test]
+fn smoke_async_stream_to_std_listener() -> io::Result<()> {
+    use std::io::Read;
+
+    let std_listener = std::net::TcpListener::bind("127.0.0.1:0")?;
+    let addr = std_listener.local_addr()?;
+
+    task::block_on(async move {
+        let mut stream = TcpStream::connect(&addr).await?;
+        stream.write_all(THE_WINTERS_TALE).await?;
+        io::Result::Ok(())
+    })?;
+
+    let mut buf = vec![0; 1024];
+    let mut incoming = std_listener.incoming();
+    let mut stream = incoming.next().unwrap()?;
+
+    let n = stream.read(&mut buf).unwrap();
+    assert_eq!(&buf[..n], THE_WINTERS_TALE);
+
+    Ok(())
+}