mirror of
https://github.com/OMGeeky/tarpc.git
synced 2026-01-06 19:45:25 +01:00
Fix up imports
This commit is contained in:
@@ -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<Req, Resp>() -> (
|
||||
Pin<Box<BaseChannel<Req, Resp, UnboundedChannel<ClientMessage<Req>, Response<Resp>>>>>,
|
||||
|
||||
@@ -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() {
|
||||
|
||||
@@ -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};
|
||||
|
||||
|
||||
Reference in New Issue
Block a user