o
    `šjÎ  ã                   @   s   G d d„ de ƒZdS )c                       sN   e Zd Z‡ fdd„Zddd„Zdd„ Zdd	„ Zd
d„ Zdd„ Zdd„ Z	‡  Z
S )Ú
KafkaBytesc                    s   t ƒ  |¡ d| _d S )Né    )ÚsuperÚ__init__Ú_idx)ÚselfÚsize©Ú	__class__© úR/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/kafka/protocol/frame.pyr      s   
zKafkaBytes.__init__Nc                 C   sT   |d u rt | ƒ| j }| j}|  j|7  _| jt | ƒkr!t | ƒ| _t| || j… ƒS ©N)Úlenr   Úbytes)r   ÚnbytesÚstartr
   r
   r   Úread   s   
zKafkaBytes.readc                 C   s*   | j }|  j t|ƒ7  _ || || j …< d S r   )r   r   )r   Údatar   r
   r
   r   Úwrite   s   zKafkaBytes.writec                 C   s
   || _ d S r   ©r   )r   Úidxr
   r
   r   Úseek   s   
zKafkaBytes.seekc                 C   s   | j S r   r   ©r   r
   r
   r   Útell   s   zKafkaBytes.tellc                 C   s   dt | ƒ S )NzKafkaBytes(%d))r   r   r
   r
   r   Ú__str__   s   zKafkaBytes.__str__c                 C   s   t | ƒS r   )Ústrr   r
   r
   r   Ú__repr__   s   zKafkaBytes.__repr__r   )Ú__name__Ú
__module__Ú__qualname__r   r   r   r   r   r   r   Ú__classcell__r
   r
   r   r   r      s    
	r   N)Ú	bytearrayr   r
   r
   r
   r   Ú<module>   s    