File tree Expand file tree Collapse file tree 1 file changed +4
-17
lines changed Expand file tree Collapse file tree 1 file changed +4
-17
lines changed Original file line number Diff line number Diff line change 13
13
# limitations under the License.
14
14
15
15
import warnings
16
- from typing import Callable
17
16
18
17
try :
19
18
import snappy
@@ -105,12 +104,6 @@ def get_compression_context(self, compressors):
105
104
return ZstdContext ()
106
105
107
106
108
- def _zlib_no_compress (data , level = None ):
109
- """Compress data with zlib level 0."""
110
- cobj = zlib .compressobj (0 )
111
- return b"" .join ([cobj .compress (data ), cobj .flush ()])
112
-
113
-
114
107
class SnappyContext (object ):
115
108
compressor_id = 1
116
109
@@ -123,16 +116,10 @@ class ZlibContext(object):
123
116
compressor_id = 2
124
117
125
118
def __init__ (self , level ):
126
- self .compress : Callable [[bytes ], bytes ]
127
-
128
- # Jython zlib.compress doesn't support -1
129
- if level == - 1 :
130
- self .compress = zlib .compress
131
- # Jython zlib.compress also doesn't support 0
132
- elif level == 0 :
133
- self .compress = _zlib_no_compress
134
- else :
135
- self .compresss = lambda data , _ : zlib .compress (data , level )
119
+ self .level = level
120
+
121
+ def compress (self , data : bytes ) -> bytes :
122
+ return zlib .compress (data , self .level )
136
123
137
124
138
125
class ZstdContext (object ):
You can’t perform that action at this time.
0 commit comments