Use piper instead of async-pipe in tests (#96)

Since we were using a fork of an old library, just pulled in the smol
equivalent.

Signed-off-by: Ben Brandt <benjamin.j.brandt@gmail.com>

Author: benbrandt

Cargo.lock

@@ -43,6 +43,12 @@ serde = { version = "1.0", features = ["derive", "rc"] }
 serde_json = { version = "1.0", features = ["raw_value"] }
 
 [dev-dependencies]
+env_logger = "0.11"
+futures-util = { version = "0.3", features = ["io"] }
+piper = "0.2"
+pretty_assertions = "1.4.1"
+rustyline = "17.0.1"
+tokio-util = { version = "0.7.16", features = ["compat"] }
 tokio = { version = "1.0", features = [
     "macros",
     "rt",
@@ -53,9 +59,3 @@ tokio = { version = "1.0", features = [
     "process",
     "sync",
 ] }
-tokio-util = { version = "0.7.16", features = ["compat"] }
-futures-util = { version = "0.3", features = ["io"] }
-async-pipe = { git = "https://github.com/zed-industries/async-pipe-rs", rev = "82d00a04211cf4e1236029aa03e6b6ce2a74c553" }
-env_logger = "0.11"
-rustyline = "17.0.1"
-pretty_assertions = "1.4.1"

Cargo.toml

@@ -252,8 +252,8 @@ async fn create_connection_pair(
     client: TestClient,
     agent: TestAgent,
 ) -> (ClientSideConnection, AgentSideConnection) {
-    let (client_to_agent_tx, client_to_agent_rx) = async_pipe::pipe();
-    let (agent_to_client_tx, agent_to_client_rx) = async_pipe::pipe();
+    let (client_to_agent_rx, client_to_agent_tx) = piper::pipe(1024);
+    let (agent_to_client_rx, agent_to_client_tx) = piper::pipe(1024);
 
     let (agent_conn, agent_io_task) = ClientSideConnection::new(
         client.clone(),