lz4.py 541 B

1234567891011121314151617181920
  1. from lz4.frame import compress as _compress
  2. from lz4.frame import decompress as _decompress
  3. from ..exceptions import CompressorError
  4. from .base import BaseCompressor
  5. class Lz4Compressor(BaseCompressor):
  6. min_length = 15
  7. def compress(self, value: bytes) -> bytes:
  8. if len(value) > self.min_length:
  9. return _compress(value)
  10. return value
  11. def decompress(self, value: bytes) -> bytes:
  12. try:
  13. return _decompress(value)
  14. except Exception as e:
  15. raise CompressorError(e)