1 files changed, 5 insertions, 29 deletions

diff --git a/tokio/tests/uds_datagram.rs b/tokio/tests/uds_datagram.rs
index d3c3535e..bd47f19e 100644
--- a/tokio/tests/uds_datagram.rs
+++ b/tokio/tests/uds_datagram.rs
@@ -6,8 +6,9 @@ use tokio::net::UnixDatagram;
 use tokio::try_join;
 
 use std::io;
+use std::sync::Arc;
 
-async fn echo_server(mut socket: UnixDatagram) -> io::Result<()> {
+async fn echo_server(socket: UnixDatagram) -> io::Result<()> {
     let mut recv_buf = vec![0u8; 1024];
     loop {
         let (len, peer_addr) = socket.recv_from(&mut recv_buf[..]).await?;
@@ -32,7 +33,7 @@ async fn echo() -> io::Result<()> {
     });
 
     {
-        let mut socket = UnixDatagram::bind(&client_path).unwrap();
+        let socket = UnixDatagram::bind(&client_path).unwrap();
         socket.connect(server_path)?;
         socket.send(b"ECHO").await?;
         let mut recv_buf = [0u8; 16];
@@ -87,8 +88,8 @@ async fn try_send_recv_never_block() -> io::Result<()> {
 async fn split() -> std::io::Result<()> {
     let dir = tempfile::tempdir().unwrap();
     let path = dir.path().join("split.sock");
-    let socket = UnixDatagram::bind(path.clone())?;
-    let (mut r, mut s) = socket.into_split();
+    let s = Arc::new(UnixDatagram::bind(path.clone())?);
+    let r = s.clone();
 
     let msg = b"hello";
     let ((), ()) = try_join! {
@@ -106,28 +107,3 @@ async fn split() -> std::io::Result<()> {
 
     Ok(())
 }
-
-#[tokio::test]
-async fn reunite() -> std::io::Result<()> {
-    let dir = tempfile::tempdir().unwrap();
-    let path = dir.path().join("reunite.sock");
-    let socket = UnixDatagram::bind(path)?;
-    let (s, r) = socket.into_split();
-    assert!(s.reunite(r).is_ok());
-    Ok(())
-}
-
-#[tokio::test]
-async fn reunite_error() -> std::io::Result<()> {
-    let dir = tempfile::tempdir().unwrap();
-    let path = dir.path().join("reunit.sock");
-    let dir = tempfile::tempdir().unwrap();
-    let path1 = dir.path().join("reunit.sock");
-    let socket = UnixDatagram::bind(path)?;
-    let socket1 = UnixDatagram::bind(path1)?;
-
-    let (s, _) = socket.into_split();
-    let (_, r1) = socket1.into_split();
-    assert!(s.reunite(r1).is_err());
-    Ok(())
-}