@@ -167,7 +167,7 @@ def encode(self, buf):
167
167
finally :
168
168
blosc .set_blocksize (old )
169
169
170
- def decode (self , buf ): # FIXME , out=None):
170
+ def decode (self , buf ): # FIXME , out=None):
171
171
buf = ensure_contiguous_ndarray (buf , self .max_buffer_size )
172
172
return blosc .decompress (buf )
173
173
@@ -177,7 +177,6 @@ def decode_partial(self, buf, start, nitems, out=None):
177
177
# return blosc.decompress_partial(buf, start, nitems, dest=out)
178
178
raise Exception ("FIXME" )
179
179
180
-
181
180
def __repr__ (self ):
182
181
r = '%s(cname=%r, clevel=%r, shuffle=%s, blocksize=%s)' % \
183
182
(type (self ).__name__ ,
@@ -187,8 +186,9 @@ def __repr__(self):
187
186
self .blocksize )
188
187
return r
189
188
190
- def compress (source , cname , clevel : int , shuffle :int = Blosc .SHUFFLE ,
191
- blocksize :int = AUTOBLOCKS ):
189
+
190
+ def compress (source , cname , clevel : int , shuffle : int = Blosc .SHUFFLE ,
191
+ blocksize : int = AUTOBLOCKS ):
192
192
"""Compress data.
193
193
194
194
Parameters
@@ -233,16 +233,17 @@ def compress(source, cname, clevel: int, shuffle:int = Blosc.SHUFFLE,
233
233
blosc .set_blocksize (old )
234
234
235
235
236
-
237
236
# FIXME: Mirroring methods. To be better defined and possibly deprecated
238
237
239
238
def cbuffer_sizes (* args , ** kwargs ):
240
239
return blosc .get_cbuffer_sizes (* args , ** kwargs )
241
240
241
+
242
242
def cbuffer_complib (enc ):
243
243
return blosc .get_clib (enc )
244
244
245
+
245
246
# FIXME
246
- #def cbuffer_metainfo(enc):
247
+ # def cbuffer_metainfo(enc):
247
248
# from blosc import blosc_extension as _ext
248
249
# return _ext.cbuffer_metainfo(enc)
0 commit comments