U bh @sxdZddlmZddlZddlmZiZiZiZdZ d%ddZ dd Z d d Z d d Z ddZddZe ejejdddgdz ddlZWnek rYnXe ejejdddgdz ddlZWnek rYnXe ejejddgdz ddlZWnek rYnXe ejejdddgdz ddlZWnek rNYn&XddZd d!Ze eed"d#d$gddS)&zCompression utilities.) annotationsN) ensure_bytes)registerencoders get_encoder get_decodercompress decompresscs0|t<|t<|r,tfdd|DdS)aRegister new compression method. Arguments: --------- encoder (Callable): Function used to compress text. decoder (Callable): Function used to decompress previously compressed text. content_type (str): The mime type this compression method identifies as. aliases (Sequence[str]): A list of names to associate with this compression method. c3s|]}|fVqdSN).0alias content_typer 5/tmp/pip-unpacked-wheel-earovzxb/kombu/compression.py !szregister..N) _encoders _decoders_aliasesupdate)encoderdecoderraliasesr rrrs rcCsttS)z/Return a list of available compression methods.)listrr r r rr$srcCst||}t||fS)zGet encoder by alias name.)rgetrtr r rr)s rcCstt||S)zGet decoder by alias name.)rrrrr r rr/srcCst|\}}|t||fS)zCompress text. Arguments: --------- body (AnyStr): The text to compress. content_type (str): mime-type of compression method to use. )rr)bodyrrr r rr4s rcCs t||S)zDecompress compressed text. Arguments: --------- body (AnyStr): Previously compressed text to uncompress. content_type (str): mime-type of compression method used. )r)rrr r rr @sr zapplication/x-gzipgzipzlib)rzapplication/x-bz2bzip2Zbzipzapplication/x-brotlibrotlizapplication/x-lzmalzmaxzcCst}||Sr )zstdZZstdCompressorr)rcr r r zstd_compressosr&cCst}||Sr )r$ZZstdDecompressorr )rdr r rzstd_decompressssr(zapplication/zstdr$ zstandard)N)__doc__ __future__rrZkombu.utils.encodingrrrr__all__rrrrrr bz2 ImportErrorr!r"r)r$r&r(r r r rsp