U
    d/ew                     @   sP   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 )    )block   )BaseCompressorBaseDecompressor   )CompressionMethodCompressionMethodBytec                   @   s$   e Zd ZejZejZdZdd Z	dS )
Compressordefaultc                 C   s   t j|d| jdS )NF)Z
store_sizemode)r   compressr   )selfdata r   E/tmp/pip-unpacked-wheel-mds_o03w/clickhouse_driver/compression/lz4.pycompress_data   s    zCompressor.compress_dataN)
__name__
__module____qualname__r   LZ4methodr   method_byter   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   N)
Zlz4r   baser   r   protocolr   r   r	   r   r   r   r   r   <module>   s   	