From a3d00b07daa38add748401e40055de556ff3754c Mon Sep 17 00:00:00 2001
From: Tim Kuehn <tikue@google.com>
Date: Tue, 2 Jan 2024 13:45:37 -0800
Subject: [PATCH] Update imports for serde_transport unit tests

---
 tarpc/src/serde_transport.rs | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/tarpc/src/serde_transport.rs b/tarpc/src/serde_transport.rs
index a8eedd5..9b3c9d6 100644
--- a/tarpc/src/serde_transport.rs
+++ b/tarpc/src/serde_transport.rs
@@ -561,7 +561,7 @@ pub mod unix {
 mod tests {
     use super::Transport;
     use assert_matches::assert_matches;
-    use futures::{task::*, Sink, Stream};
+    use futures::{task::*, Sink, SinkExt, Stream, StreamExt};
     use pin_utils::pin_mut;
     use std::{
         io::{self, Cursor},
@@ -698,7 +698,6 @@ mod tests {
     #[tokio::test]
     async fn uds() -> io::Result<()> {
         use super::unix;
-        use super::*;
 
         let sock = unix::TempPathBuf::with_random("uds");
         let mut listener = unix::listen(&sock, SymmetricalJson::<String>::default).await?;
@@ -718,7 +717,6 @@ mod tests {
     #[tokio::test]
     async fn uds_on_existing_transport() -> io::Result<()> {
         use super::unix;
-        use super::*;
 
         let sock = unix::TempPathBuf::with_random("uds");
         let transport = tokio::net::UnixListener::bind(&sock)?;