o
    FDi                     @   sX   d dl Z d dlm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)block)BaseCompressorBaseDecompressor)CompressionMethodCompressionMethodBytec                   @   s6   e Zd ZejZejZej	e
jdddZdZdd ZdS )
CompressordefaultF)mode
store_sizec                 C   s   t j|d| jdS )NF)r
   r	   )r   compressr	   )selfdata r   U/var/www/Datamplify/venv/lib/python3.10/site-packages/asynch/proto/compression/lz4.pycompress_data   s   zCompressor.compress_dataN)__name__
__module____qualname__r   LZ4methodr   method_byte	functoolspartialr   r   compress_funcr	   r   r   r   r   r   r   	   s    r   c                   @   s    e Zd ZejZejZdd ZdS )Decompressorc                 C   s   t j||dS )N)uncompressed_size)r   
decompress)r   r   r   r   r   r   decompress_data   s   zDecompressor.decompress_dataN)	r   r   r   r   r   r   r   r   r   r   r   r   r   r      s    r   )r   lz4r   asynch.proto.compressionr   r   asynch.proto.protocolr   r   r   r   r   r   r   r   <module>   s    
