Add muxer compliance test suite and refactor tests to not depend on libp2p-swarm

transports/quic/Cargo.toml

@@ -40,8 +40,13 @@ rustc-args = ["--cfg", "docsrs"]
 
 [dev-dependencies]
 async-std = { version = "1.12.0", features = ["attributes"] }
-libp2p = { path = "../..", features = ["request-response", "tcp", "yamux", "noise", "async-std"] }
 env_logger = "0.9.0"
-rand = "0.8.4"
-tokio = { version = "1.21.1", features = ["macros", "rt-multi-thread"] }
+libp2p = { path = "../..", features = ["tcp", "yamux", "noise", "async-std"] }
+libp2p-muxer-test-harness = { path = "../../muxers/test-harness" }
 quickcheck = "1"
+rand = "0.8.4"
+tokio = { version = "1.21.1", features = ["macros", "rt-multi-thread", "time"] }
+
+[[test]]
+name = "stream_compliance"
+required-features = ["async-std"]

transports/quic/src/connection/substream.rs

@@ -191,7 +191,10 @@ impl AsyncWrite for Substream {
                 Poll::Ready(Err(io::Error::new(io::ErrorKind::ConnectionReset, err)))
             }
             Err(quinn_proto::FinishError::UnknownStream) => {
-                Poll::Ready(Err(io::ErrorKind::BrokenPipe.into()))
+                // We never make up IDs so the stream must have existed at some point if we get to here.
+                // `UnknownStream` is also emitted in case the stream is already finished, hence just
+                // return `Ok(())` here.
+                Poll::Ready(Ok(()))
             }
         }
     }