summaryrefslogtreecommitdiffhomepage
path: root/test
diff options
context:
space:
mode:
Diffstat (limited to 'test')
-rw-r--r--test/test-rpc/src/transport.rs33
1 files changed, 17 insertions, 16 deletions
diff --git a/test/test-rpc/src/transport.rs b/test/test-rpc/src/transport.rs
index 753420900d..291e08eb53 100644
--- a/test/test-rpc/src/transport.rs
+++ b/test/test-rpc/src/transport.rs
@@ -120,16 +120,18 @@ impl ConnectionHandle {
}
}
-pub fn create_server_transports(
- serial_stream: impl AsyncRead + AsyncWrite + Unpin + Send + 'static,
-) -> (
+type ServerTransports = (
tarpc::transport::channel::UnboundedChannel<
ClientMessage<ServiceRequest>,
Response<ServiceResponse>,
>,
GrpcForwarder,
CompletionHandle,
-) {
+);
+
+pub fn create_server_transports(
+ serial_stream: impl AsyncRead + AsyncWrite + Unpin + Send + 'static,
+) -> ServerTransports {
let (runner_forwarder_1, runner_forwarder_2) = tarpc::transport::channel::unbounded();
let (daemon_rx, mullvad_daemon_forwarder) = tokio::io::duplex(DAEMON_CHANNEL_BUF_SIZE);
@@ -164,18 +166,7 @@ pub fn create_server_transports(
pub fn create_client_transports(
serial_stream: impl AsyncRead + AsyncWrite + Unpin + Send + 'static,
-) -> Result<
- (
- tarpc::transport::channel::UnboundedChannel<
- Response<ServiceResponse>,
- ClientMessage<ServiceRequest>,
- >,
- GrpcForwarder,
- ConnectionHandle,
- CompletionHandle,
- ),
- Error,
-> {
+) -> Result<ClientTransports, Error> {
let (runner_forwarder_1, runner_forwarder_2) = tarpc::transport::channel::unbounded();
let (daemon_rx, mullvad_daemon_forwarder) = tokio::io::duplex(DAEMON_CHANNEL_BUF_SIZE);
@@ -216,6 +207,16 @@ pub fn create_client_transports(
))
}
+type ClientTransports = (
+ tarpc::transport::channel::UnboundedChannel<
+ Response<ServiceResponse>,
+ ClientMessage<ServiceRequest>,
+ >,
+ GrpcForwarder,
+ ConnectionHandle,
+ CompletionHandle,
+);
+
#[derive(err_derive::Error, Debug)]
#[error(no_from)]
enum ForwardError {