From bc0de9955c375cf27d52c9934403964205afc182 Mon Sep 17 00:00:00 2001 From: salmonik Date: Thu, 29 Oct 2026 22:16:15 +0100 Subject: formatting --- src/bin/client/tls.rs | 17 ++++++++--------- 1 file changed, 8 insertions(+), 9 deletions(-) (limited to 'src/bin/client/tls.rs') diff --git a/src/bin/client/tls.rs b/src/bin/client/tls.rs index b46f52b..e14ed98 100644 --- a/src/bin/client/tls.rs +++ b/src/bin/client/tls.rs @@ -17,10 +17,10 @@ use std::net::TcpStream; use std::sync::Arc; use parking_lot::Mutex; -use rustls::client::{HandshakeSignatureValid, ServerCertVerified, ServerCertVerifier}; use rustls::DigitallySignedStruct; +use rustls::client::{HandshakeSignatureValid, ServerCertVerified, ServerCertVerifier}; use zagan_bet::protocol::LineBuffer; -use zagan_bet::tofu::{decide, spki_fingerprint, TrustDecision}; +use zagan_bet::tofu::{TrustDecision, decide, spki_fingerprint}; pub struct TlsConnector { config: Arc, @@ -53,7 +53,10 @@ impl TlsConnector { }) } - pub fn connect(&self, stream: TcpStream) -> Result> { + pub fn connect( + &self, + stream: TcpStream, + ) -> Result> { let mut conn = rustls::ClientConnection::new(Arc::clone(&self.config), self.server_name.clone())?; let mut sock = stream; @@ -200,10 +203,7 @@ impl TlsStream { } /// Apply a read timeout to the underlying TCP socket. - pub fn set_read_timeout( - &self, - duration: Option, - ) -> std::io::Result<()> { + pub fn set_read_timeout(&self, duration: Option) -> std::io::Result<()> { let mut s = self.session.lock(); s.read_timeout = duration; s.sock.set_read_timeout(duration) @@ -235,8 +235,7 @@ impl TlsStream { Err(error) if matches!( error.kind(), - std::io::ErrorKind::WouldBlock - | std::io::ErrorKind::TimedOut + std::io::ErrorKind::WouldBlock | std::io::ErrorKind::TimedOut ) => { return Ok(()); -- cgit v1.2.3