diff --git a/tarpc/src/server.rs b/tarpc/src/server.rs index abf964c..b6dce52 100644 --- a/tarpc/src/server.rs +++ b/tarpc/src/server.rs @@ -750,16 +750,14 @@ where mod tests { use super::*; - use { - crate::{ - trace, - transport::channel::{self, UnboundedChannel}, - }, - assert_matches::assert_matches, - futures::future::{pending, Aborted}, - futures_test::task::noop_context, - std::time::Duration, + use crate::{ + trace, + transport::channel::{self, UnboundedChannel}, }; + use assert_matches::assert_matches; + use futures::future::{pending, Aborted}; + use futures_test::task::noop_context; + use std::time::Duration; fn test_channel() -> ( Pin, Response>>>>, diff --git a/tarpc/src/server/in_flight_requests.rs b/tarpc/src/server/in_flight_requests.rs index 9a1a16d..3399e26 100644 --- a/tarpc/src/server/in_flight_requests.rs +++ b/tarpc/src/server/in_flight_requests.rs @@ -121,14 +121,12 @@ impl Drop for InFlightRequests { mod tests { use super::*; - use { - assert_matches::assert_matches, - futures::{ - future::{pending, Abortable}, - FutureExt, - }, - futures_test::task::noop_context, + use assert_matches::assert_matches; + use futures::{ + future::{pending, Abortable}, + FutureExt, }; + use futures_test::task::noop_context; #[tokio::test] async fn start_request_increases_len() { diff --git a/tarpc/src/server/throttle.rs b/tarpc/src/server/throttle.rs index bac2029..04181b2 100644 --- a/tarpc/src/server/throttle.rs +++ b/tarpc/src/server/throttle.rs @@ -174,9 +174,13 @@ where mod tests { use super::*; - use super::super::in_flight_requests::AlreadyExistsError; - use super::super::testing::{self, FakeChannel, PollExt}; - use crate::Request; + use crate::{ + server::{ + in_flight_requests::AlreadyExistsError, + testing::{self, FakeChannel, PollExt}, + }, + Request, + }; use pin_utils::pin_mut; use std::{marker::PhantomData, time::Duration};