fix: check rsv1 even if deflate enabled

PrivateRookie · Nov 23, 2023 · f036f05 · f036f05
1 parent f1ffef8
commit f036f05
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/codec/deflate/blocking.rs b/src/codec/deflate/blocking.rs
@@ -173,7 +173,7 @@ impl DeflateReadState {
                 error: ProtocolError::CompressedControlFrame,
             });
         }
-        if !is_data_frame {
+        if !is_data_frame || !compressed {
             return Ok((header, data));
         }
         let frame = match self.de.as_mut() {

diff --git a/src/codec/deflate/non_blocking.rs b/src/codec/deflate/non_blocking.rs
@@ -174,7 +174,7 @@ impl DeflateReadState {
                 error: ProtocolError::CompressedControlFrame,
             });
         }
-        if !is_data_frame {
+        if !is_data_frame || !compressed {
             return Ok((header, data.to_vec()));
         }
         let frame = match self.de.as_mut() {