make async-oriented, remove block_on

[connect-rs.git] / src / tcp / client.rs

diff --git a/src/tcp/client.rs b/src/tcp/client.rs
index e9cd42bfc395b511675c4dabaf092ed11822f2e1..221825da27399ad7ab477a13be1a979b7179abcf 100644 (file)
--- a/src/tcp/client.rs
+++ b/src/tcp/client.rs
@@ -4,8 +4,10 @@ use crate::Connection;
 use async_std::net::{TcpStream, ToSocketAddrs};
 
 impl Connection {
-    pub fn tcp_client<A: ToSocketAddrs + std::fmt::Display>(ip_addrs: A) -> anyhow::Result<Self> {
-        let stream = futures::executor::block_on(TcpStream::connect(&ip_addrs))?;
+    pub async fn tcp_client<A: ToSocketAddrs + std::fmt::Display>(
+        ip_addrs: A,
+    ) -> anyhow::Result<Self> {
+        let stream = TcpStream::connect(&ip_addrs).await?;
         info!("Established client TCP connection to {}", ip_addrs);
 
         stream.set_nodelay(true)?;