File: //proc/self/root/usr/local/lib/python3.9/site-packages/kombu/__pycache__/compression.cpython-39.pyc
a
X>h� � @ sp d Z ddlmZ ddlZddlmZ i Zi Zi ZdZ d%dd�Z
dd � Z d
d � Z d d
� Z
dd� Zdd� Ze
ejejdddgd� z ddlZW n ey� Y n0 e
ejejdddgd� z ddlZW n ey� Y n0 e
ejejddgd� z ddlZW n e�y Y n0 e
ejejdd d gd� z ddlZW n e�yF Y n&0 d d � Zd d!� Ze
eed"d#d$gd� dS )&zCompression utilities.� )� annotationsN)� ensure_bytes)�register�encoders� get_encoder� get_decoder�compress�
decompressc s0 | t � < |t� < |r,t�� fdd�|D �� dS )a� Register 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.
c 3 s | ]}|� fV qd S �N� )�.0�alias�� content_typer �;/usr/local/lib/python3.9/site-packages/kombu/compression.py� <genexpr>! � zregister.<locals>.<genexpr>N)� _encoders� _decoders�_aliases�update)�encoder�decoderr �aliasesr r r r s
r c C s t t�S )z/Return a list of available compression methods.)�listr r r r r r $ s r c C s t �| | �} t| | fS )zGet encoder by alias name.)r �getr ��tr r r r ) s r c C s t t�| | � S )zGet decoder by alias name.)r r r r r r r r / s r c C s t |�\}}|t| ��|fS )z�Compress text.
Arguments:
---------
body (AnyStr): The text to compress.
content_type (str): mime-type of compression method to use.
)r r )�bodyr r r r r r 4 s r c C s t |�| �S )z�Decompress compressed text.
Arguments:
---------
body (AnyStr): Previously compressed text to uncompress.
content_type (str): mime-type of compression method used.
)r )r r r r r r @ s r zapplication/x-gzip�gzip�zlib)r zapplication/x-bz2�bzip2Zbzipzapplication/x-brotli�brotlizapplication/x-lzma�lzma�xzc C s t �� }|�| �S r
)�zstdZZstdCompressorr )r �cr r r �
zstd_compresso s r' c C s t �� }|�| �S r
)r% ZZstdDecompressorr )r �dr r r �zstd_decompresss s r) zapplication/zstdr% � zstandard)N)�__doc__�
__future__r r Zkombu.utils.encodingr r r r �__all__r r r r r r �bz2� ImportErrorr" r# r* r% r' r) r r r r �<module> sf
� � � � �