From 4bb05f3698e8d700612b34cc4b7540d8db4e54c5 Mon Sep 17 00:00:00 2001 From: mfahampshire Date: Wed, 27 Nov 2024 14:06:26 +0100 Subject: [PATCH] err handling conpool start --- sdk/rust/nym-sdk/src/tcp_proxy/tcp_proxy_client.rs | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/sdk/rust/nym-sdk/src/tcp_proxy/tcp_proxy_client.rs b/sdk/rust/nym-sdk/src/tcp_proxy/tcp_proxy_client.rs index 306bdb5ec9..2b2c0107b2 100644 --- a/sdk/rust/nym-sdk/src/tcp_proxy/tcp_proxy_client.rs +++ b/sdk/rust/nym-sdk/src/tcp_proxy/tcp_proxy_client.rs @@ -73,8 +73,12 @@ impl NymProxyClient { TcpListener::bind(format!("{}:{}", self.listen_address, self.listen_port)).await?; let client_maker = self.conn_pool.clone(); - tokio::spawn(async move { client_maker.start().await.unwrap() }); + tokio::spawn(async move { + client_maker.start().await?; + Ok::<(), anyhow::Error>(()) + }); + // TODO add 'ready' marker for consuming code loop { if DEFAULT_CLIENT_POOL_SIZE == 1 && self.conn_pool.get_client_count().await == 1 || self.conn_pool.get_client_count().await >= DEFAULT_CLIENT_POOL_SIZE / 2