summaryrefslogtreecommitdiff
path: root/light-client
diff options
context:
space:
mode:
authormetamuffin <metamuffin@disroot.org>2024-07-15 17:52:33 +0200
committermetamuffin <metamuffin@disroot.org>2024-07-15 17:52:33 +0200
commitb66e12ccd8823ffeaff23e2b4e5426cb15f59c99 (patch)
treee117b0082e9e37702d609dabca8ab1a476a60a74 /light-client
parente0b3182f4dbd50ec8aac12470d13bfef8231989e (diff)
downloadhurrycurry-b66e12ccd8823ffeaff23e2b4e5426cb15f59c99.tar
hurrycurry-b66e12ccd8823ffeaff23e2b4e5426cb15f59c99.tar.bz2
hurrycurry-b66e12ccd8823ffeaff23e2b4e5426cb15f59c99.tar.zst
set websocket nonblocking
Diffstat (limited to 'light-client')
-rw-r--r--light-client/src/network.rs9
1 files changed, 7 insertions, 2 deletions
diff --git a/light-client/src/network.rs b/light-client/src/network.rs
index f2c42518..3eb3f50a 100644
--- a/light-client/src/network.rs
+++ b/light-client/src/network.rs
@@ -59,9 +59,14 @@ impl Network {
});
let stream = TcpStream::connect((host, port))?;
stream.set_nodelay(true).unwrap();
- // stream.set_nonblocking(true).unwrap();
- let (sock, _) = client_tls_with_config(request, stream, None, None).unwrap();
+ let (mut sock, _) = client_tls_with_config(request, stream, None, None).unwrap();
+
+ match sock.get_mut() {
+ MaybeTlsStream::Plain(s) => s.set_nonblocking(true).unwrap(),
+ MaybeTlsStream::Rustls(s) => s.sock.set_nonblocking(true).unwrap(),
+ _ => todo!(),
+ };
Ok(Self {
sock,