From 5c562b2ff5d93e16ebe058e17bda2bc0505e7b45 Mon Sep 17 00:00:00 2001 From: Matteo Settenvini Date: Wed, 3 May 2023 07:33:17 +0200 Subject: [PATCH] Rename addr <-> url --- grpc/broadcaster/src/main.rs | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/grpc/broadcaster/src/main.rs b/grpc/broadcaster/src/main.rs index 6156b94..8dfd6e0 100644 --- a/grpc/broadcaster/src/main.rs +++ b/grpc/broadcaster/src/main.rs @@ -27,8 +27,8 @@ const RENDEZVOUS: &'static str = "[::1]:10000"; #[tokio::main(flavor = "current_thread")] async fn main() -> Result<(), Box> { - let url = RENDEZVOUS.parse()?; - let incoming = TcpIncoming::new(url, true, None).expect("Cannot bind server socket"); + let addr = RENDEZVOUS.parse()?; + let incoming = TcpIncoming::new(addr, true, None).expect("Cannot bind server socket"); run_server(incoming).await?; Ok(()) } @@ -127,8 +127,8 @@ mod test { #[tokio::test] async fn bidi_streaming() -> Result<(), Box> { - let url = RENDEZVOUS.parse()?; - let incoming = TcpIncoming::new(url, true, None).expect("Cannot bind server socket"); + let addr = RENDEZVOUS.parse()?; + let incoming = TcpIncoming::new(addr, true, None).expect("Cannot bind server socket"); tokio::spawn(run_server(incoming)); // This is the number of messages to broadcast @@ -137,8 +137,8 @@ mod test { const CLIENT_IDS: &[&str] = &["client AAA", "client BBB", "client CCC"]; async fn client(id: &str, mock: &MockMessageChecker) { - let addr = format!("http://{}", RENDEZVOUS); - let mut client = ServiceClient::connect(addr).await.unwrap(); + let url = format!("http://{}", RENDEZVOUS); + let mut client = ServiceClient::connect(url).await.unwrap(); let client_id = String::from(id); let outbound = async_stream::stream! {