o
    `šjå  ã                   @   s4   d dl mZmZ G dd„ deƒZG dd„ deƒZdS )é   )ÚDeserializerÚ
Serializerc                   @   ó   e Zd Zdd„ Zdd„ ZdS )ÚDeserializeWrapperc                 C   ó
   || _ d S ©N©Úfn©Úselfr	   © r   úV/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/kafka/serializer/wrapper.pyÚ__init__   ó   
zDeserializeWrapper.__init__c                 C   ó   | j d u r|S |   |¡S r   r   ©r   ÚtopicÚheadersÚdatar   r   r   Údeserialize   ó   

zDeserializeWrapper.deserializeN)Ú__name__Ú
__module__Ú__qualname__r   r   r   r   r   r   r      ó    r   c                   @   r   )ÚSerializeWrapperc                 C   r   r   r   r
   r   r   r   r      r   zSerializeWrapper.__init__c                 C   r   r   r   r   r   r   r   Ú	serialize   r   zSerializeWrapper.serializeN)r   r   r   r   r   r   r   r   r   r      r   r   N)Úabstractr   r   r   r   r   r   r   r   Ú<module>   s    
