#![cfg(feature = "tokio_support")]
#[path = "../util/mod.rs"]
mod util;
use util::TestResult;
mod no_server;
mod stream;
use {interprocess::local_socket::NameTypeSupport, tokio::try_join};
#[tokio::test]
async fn tokio_local_socket_stream() -> TestResult {
use stream::*;
let f1 = util::tokio::drive_server_and_multiple_clients(|s, n| server(s, n, false), client);
if NameTypeSupport::query() == NameTypeSupport::Both {
let f2 = util::tokio::drive_server_and_multiple_clients(|s, n| server(s, n, true), client);
try_join!(f1, f2)?;
} else {
f1.await?;
}
Ok(())
}
#[tokio::test]
async fn tokio_local_socket_no_server() -> TestResult {
let f1 = no_server::run_and_verify_error(false);
if NameTypeSupport::query() == NameTypeSupport::Both {
let f2 = no_server::run_and_verify_error(true);
try_join!(f1, f2)?;
} else {
f1.await?;
}
Ok(())
}