o
    FD©i€  ã                   @   sL   d dl Z d dlmZmZ d dlmZmZ G dd„ deƒZG dd„ deƒZdS )é    N)ÚBaseCompressorÚBaseDecompressor)ÚCompressionMethodÚCompressionMethodBytec                   @   ó&   e Zd ZejZejZej	Z
dd„ ZdS )Ú
Compressorc                 C   s   t  t|ƒ¡S ©N)ÚzstdÚcompressÚbytes)ÚselfÚdata© r   úV/var/www/Datamplify/venv/lib/python3.10/site-packages/asynch/proto/compression/zstd.pyÚcompress_data   s   zCompressor.compress_dataN)Ú__name__Ú
__module__Ú__qualname__r   ÚZSTDÚmethodr   Úmethod_byter	   r
   Úcompress_funcr   r   r   r   r   r      ó
    r   c                   @   r   )ÚDecompressorc                 C   s
   t  |¡S r   )r	   Ú
decompress)r   r   Úuncompressed_sizer   r   r   Údecompress_data   s   
zDecompressor.decompress_dataN)r   r   r   r   r   r   r   r   r	   r   Údecompress_funcr   r   r   r   r   r      r   r   )	r	   Úasynch.proto.compressionr   r   Úasynch.proto.protocolr   r   r   r   r   r   r   r   Ú<module>   s
    	