return unpacked stream

src/client.rs

@@ -1331,7 +1331,7 @@ impl<T: Read + Write + Unpin + fmt::Debug + Send> Session<T> {
     /// and `Err` if compression was not enabled.
     pub async fn compress(
         self,
-    ) -> Result<std::result::Result<Session<DeflateStream<T>>, Session<T>>> {
+    ) -> Result<std::result::Result<DeflateStream<T>, Session<T>>> {
         let Self {
             mut conn,
             unsolicited_responses_tx,
@@ -1343,6 +1343,7 @@ impl<T: Read + Write + Unpin + fmt::Debug + Send> Session<T> {
 
         if true {
             let deflate_stream = DeflateStream::new(stream);
+            /*
             let stream = ImapStream::new(deflate_stream);
             let conn = Connection {
                 stream,
@@ -1353,7 +1354,8 @@ impl<T: Read + Write + Unpin + fmt::Debug + Send> Session<T> {
                 unsolicited_responses_tx,
                 unsolicited_responses,
             };
-            Ok(Ok(session))
+            */
+            Ok(Ok(deflate_stream))
         } else {
             let stream = ImapStream::new(stream);
             let conn = Connection {