OMGeeky/tarpc
1
0
Fork 0
mirror of https://github.com/OMGeeky/tarpc.git synced 2026-01-06 19:45:25 +01:00
Code Issues Packages Projects Releases Wiki Activity

Update imports for serde_transport unit tests

Browse Source
This commit is contained in:
Tim Kuehn
2024-01-02 13:45:37 -08:00
parent d62706e62c
commit a3d00b07da
1 changed files with 1 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
tarpc/src/serde_transport.rs
View File

@@ -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)?;