| 1234567891011121314151617181920 |
- from lz4.frame import compress as _compress
- from lz4.frame import decompress as _decompress
- from ..exceptions import CompressorError
- from .base import BaseCompressor
- class Lz4Compressor(BaseCompressor):
- min_length = 15
- def compress(self, value: bytes) -> bytes:
- if len(value) > self.min_length:
- return _compress(value)
- return value
- def decompress(self, value: bytes) -> bytes:
- try:
- return _decompress(value)
- except Exception as e:
- raise CompressorError(e)
|