
    Ii                          " S  S\ 5      rg)c                   P   ^  \ rS rSrU 4S jrS
S jrS rS rS rS r	S r
S	rU =r$ )
KafkaBytes   c                 :   > [         [        U ]  U5        SU l        g )N    )superr   __init___idx)selfsize	__class__s     :/venv/lib/python3.13/site-packages/kafka/protocol/frame.pyr   KafkaBytes.__init__   s    j$(.	    c                     Uc  [        U 5      U R                  -
  nU R                  nU =R                  U-  sl        U R                  [        U 5      :  a  [        U 5      U l        [        XU R                   5      $ N)lenr	   bytes)r
   nbytesstarts      r   readKafkaBytes.read   s_    >Y*F				V	99s4y D	DIT		*++r   c                 r    U R                   nU =R                   [        U5      -  sl         XX R                   & g r   )r	   r   )r
   datar   s      r   writeKafkaBytes.write   s)    				SY	 $U99r   c                     Xl         g r   r	   )r
   idxs     r   seekKafkaBytes.seek   s    	r   c                     U R                   $ r   r   r
   s    r   tellKafkaBytes.tell   s    yyr   c                     S[        U 5      -  $ )NzKafkaBytes(%d))r   r"   s    r   __str__KafkaBytes.__str__   s    #d)++r   c                     [        U 5      $ r   )strr"   s    r   __repr__KafkaBytes.__repr__   s    4yr   r   r   )__name__
__module____qualname____firstlineno__r   r   r   r   r#   r&   r*   __static_attributes____classcell__)r   s   @r   r   r      s+    ,%
, r   r   N)	bytearrayr    r   r   <module>r4      s    r   