Streamlined the tests

crates/xwebtransport-error/src/lib.rs

@@ -4,7 +4,6 @@ use xwebtransport_core::{prelude::*, traits};
 pub enum Connect<Endpoint>
 where
     Endpoint: traits::EndpointConnect,
-    EndpointConnectConnectionFor<Endpoint>: traits::Connection,
 {
     Connect(Endpoint::Error),
     Connecting(<Endpoint::Connecting as traits::Connecting>::Error),
@@ -14,7 +13,6 @@ where
 pub enum Accept<Endpoint>
 where
     Endpoint: traits::EndpointAccept,
-    EndpointAcceptConnectionFor<Endpoint>: traits::Connection,
 {
     Accept(Endpoint::Error),
     Connecting(<Endpoint::Connecting as traits::Connecting>::Error),

crates/xwebtransport-tests/src/tests.rs

@@ -1,20 +1,33 @@
 use tokio::io::{AsyncReadExt, AsyncWriteExt};
+use xwebtransport_core::trait_utils::EndpointConnectConnectionFor;
 
 #[derive(Debug, thiserror::Error)]
-pub enum EchoError<Connection>
+pub enum EchoError<Endpoint>
 where
-    Connection: xwebtransport_core::OpenBiStream,
+    Endpoint: xwebtransport_core::EndpointConnect + std::fmt::Debug,
+    Endpoint::Connecting: std::fmt::Debug,
+    EndpointConnectConnectionFor<Endpoint>: xwebtransport_core::OpenBiStream + std::fmt::Debug,
 {
-    Open(xwebtransport_error::OpenBi<Connection>),
+    Connect(xwebtransport_error::Connect<Endpoint>),
+    Open(xwebtransport_error::OpenBi<EndpointConnectConnectionFor<Endpoint>>),
     Send(std::io::Error),
     Recv(std::io::Error),
     BadData(Vec<u8>),
 }
 
-pub async fn echo<Connection>(connection: Connection) -> Result<(), EchoError<Connection>>
+pub async fn echo<Endpoint>(
+    endpoint: Endpoint,
+    params: Endpoint::Params<'_>,
+) -> Result<(), EchoError<Endpoint>>
 where
-    Connection: xwebtransport_core::Connection,
+    Endpoint: xwebtransport_core::EndpointConnect + std::fmt::Debug,
+    Endpoint::Connecting: std::fmt::Debug,
+    EndpointConnectConnectionFor<Endpoint>: xwebtransport_core::OpenBiStream + std::fmt::Debug,
 {
+    let connection = crate::utils::connect(endpoint, "https://echo.webtransport.day", params)
+        .await
+        .map_err(EchoError::Connect)?;
+
     let (send_stream, recv_stream) = crate::utils::open_bi(connection)
         .await
         .map_err(EchoError::Open)?;

crates/xwebtransport-tests/src/utils.rs

@@ -7,7 +7,6 @@ pub async fn connect<Endpoint>(
 ) -> Result<EndpointConnectConnectionFor<Endpoint>, xwebtransport_error::Connect<Endpoint>>
 where
     Endpoint: xwebtransport_core::EndpointConnect,
-    EndpointConnectConnectionFor<Endpoint>: xwebtransport_core::Connection,
 {
     let connecting = endpoint
         .connect(url, params)

crates/xwebtransport-web-sys/tests/test.rs

@@ -8,13 +8,7 @@ wasm_bindgen_test::wasm_bindgen_test_configure!(run_in_browser);
 async fn main() {
     let endpoint = xwebtransport_web_sys::Endpoint;
 
-    let connection = xwebtransport_tests::utils::connect(
-        endpoint,
-        "https://echo.webtransport.day",
-        &Default::default(),
-    )
-    .await
-    .unwrap();
-
-    xwebtransport_tests::tests::echo(connection).await.unwrap();
+    xwebtransport_tests::tests::echo(endpoint, &Default::default())
+        .await
+        .unwrap();
 }

crates/xwebtransport-wtransport/tests/test.rs

@@ -12,10 +12,7 @@ async fn main() {
 
     let endpoint = xwebtransport_wtransport::Endpoint(endpoint);
 
-    let connection =
-        xwebtransport_tests::utils::connect(endpoint, "https://echo.webtransport.day", ())
-            .await
-            .unwrap();
-
-    xwebtransport_tests::tests::echo(connection).await.unwrap();
+    xwebtransport_tests::tests::echo(endpoint, ())
+        .await
+        .unwrap();
 }