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