1 files changed, 8 insertions, 9 deletions

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<rustls::ClientConfig>,
@@ -53,7 +53,10 @@ impl TlsConnector {
         })
     }
 
-    pub fn connect(&self, stream: TcpStream) -> Result<TlsStream, Box<dyn std::error::Error + Send + Sync>> {
+    pub fn connect(
+        &self,
+        stream: TcpStream,
+    ) -> Result<TlsStream, Box<dyn std::error::Error + Send + Sync>> {
         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::time::Duration>,
-    ) -> std::io::Result<()> {
+    pub fn set_read_timeout(&self, duration: Option<std::time::Duration>) -> 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(());