usable

clients/client-core/src/client/real_messages_control/acknowledgement_control/acknowledgement_listener.rs

@@ -33,7 +33,7 @@ impl AcknowledgementListener {
     }
 
     async fn on_ack(&mut self, ack_content: Vec<u8>) {
-        debug!("Received an ack");
+        trace!("Received an ack");
         let frag_id = match recover_identifier(&self.ack_key, &ack_content)
             .map(FragmentIdentifier::try_from_bytes)
         {

clients/client-core/src/client/received_buffer.rs

@@ -208,7 +208,7 @@ impl ReceivedMessagesBuffer {
     }
 
     async fn handle_new_received(&mut self, msgs: Vec<Vec<u8>>) {
-        debug!(
+        trace!(
             "Processing {:?} new message that might get added to the buffer!",
             msgs.len()
         );

common/socks5/proxy-helpers/src/proxy_runner/mod.rs

@@ -111,7 +111,8 @@ where
     {
         let (read_half, write_half) = self.socket.take().unwrap().into_split();
         let shutdown_notify = Arc::new(Notify::new());
-        let chunker = Some(self.msg_chunker.as_ref().unwrap().clone_box());
+        //let chunker = Some(self.msg_chunker.as_ref().unwrap().clone_box());
+        let chunker = self.msg_chunker.as_ref().map(|c| c.clone_box());
 
         // should run until either inbound closes or is notified from outbound
         let inbound_future = inbound::run_inbound(