|
1 | | -#![allow(unused_imports)] |
2 | | - |
3 | | -use crate::test_client::TestClient; |
4 | | -use crate::*; |
5 | | -use rand::Rng as _; |
6 | | -use std::env; |
7 | | -use std::fs; |
| 1 | +use default_stubs::test_client::TestClient; |
| 2 | +use default_stubs::*; |
8 | 3 | use std::net::SocketAddr; |
9 | 4 | use tokio::net::TcpListener; |
| 5 | +use tokio_stream::{Stream, StreamExt}; |
10 | 6 | use tonic::transport::Channel; |
11 | 7 | use tonic::transport::Server; |
12 | 8 |
|
13 | | -#[cfg(test)] |
14 | 9 | fn echo_requests_iter() -> impl Stream<Item = ()> { |
15 | 10 | tokio_stream::iter(1..usize::MAX).map(|_| ()) |
16 | 11 | } |
17 | 12 |
|
18 | | -#[cfg(test)] |
19 | 13 | async fn test_default_stubs( |
20 | 14 | mut client: TestClient<Channel>, |
21 | 15 | mut client_default_stubs: TestClient<Channel>, |
@@ -100,7 +94,6 @@ async fn test_default_stubs_uds() { |
100 | 94 | test_default_stubs(client, client_default_stubs).await; |
101 | 95 | } |
102 | 96 |
|
103 | | -#[cfg(test)] |
104 | 97 | async fn run_services_in_background() -> (SocketAddr, SocketAddr) { |
105 | 98 | let svc = test_server::TestServer::new(Svc {}); |
106 | 99 | let svc_default_stubs = test_default_server::TestDefaultServer::new(Svc {}); |
@@ -132,8 +125,10 @@ async fn run_services_in_background() -> (SocketAddr, SocketAddr) { |
132 | 125 | (addr, addr_default_stubs) |
133 | 126 | } |
134 | 127 |
|
135 | | -#[cfg(all(test, not(target_os = "windows")))] |
| 128 | +#[cfg(not(target_os = "windows"))] |
136 | 129 | async fn run_services_in_background_uds() -> (String, String) { |
| 130 | + use rand::Rng as _; |
| 131 | + use std::{env, fs}; |
137 | 132 | use tokio::net::UnixListener; |
138 | 133 |
|
139 | 134 | let svc = test_server::TestServer::new(Svc {}); |
|
0 commit comments