this changed

Signed-off-by: Benjamin Leggett <benjamin.leggett@solo.io>

src/proxy/pool.rs

@@ -646,6 +646,7 @@ mod test {
     use hyper::{Request, Response};
     use std::sync::atomic::AtomicU32;
     use std::time::Duration;
+    use tokio::io::AsyncWriteExt;
     use tokio::net::TcpListener;
     use tokio::task::{self};
     use tokio::time::sleep;
@@ -1397,9 +1398,9 @@ mod test {
             tokio::task::spawn(async move {
                 match hyper::upgrade::on(req).await {
                     Ok(upgraded) => {
-                        let (mut ri, mut wi) =
-                            tokio::io::split(hyper_util::rt::TokioIo::new(upgraded));
-                        tcp::handle_stream(tcp::Mode::ReadWrite, &mut ri, &mut wi).await;
+                        let mut io = hyper_util::rt::TokioIo::new(upgraded);
+                        io.write_all(b"poolsrv\n").await.unwrap();
+                        tcp::handle_stream(tcp::Mode::ReadWrite, &mut io).await;
                     }
                     Err(e) => panic!("No upgrade {e}"),
                 }