
    #HJj0                     f    d dl Z d dlZd dlmZmZ d dlmZ d dlmZ d Zd Z	d Z
d Zd	 Zd
 Zd Zy)    N)Unpacker
BufferFull)pack)	OutOfDatac                     t               } | j                  d       t        j                  t              5  t        t        |              d d d        | j                  d       t        j                  t              5  t        t        |              d d d        | j                  d       t        j                  t              5  t        t        |              d d d        | j                  d       t        j                  t              5  t        t        |              d d d        | j                  d       t        j                  t              5  t        t        |              d d d        | j                  d       t        t        |             dk(  sJ y # 1 sw Y   QxY w# 1 sw Y   xY w# 1 sw Y   xY w# 1 sw Y   xY w# 1 sw Y   fxY w)N      h   a   l   os   hallo)r   feedpytestraisesStopIterationnextiterunpackers    l/Users/ahmed/devFolder/claude-voice/.venv/lib/python3.12/site-packages/srsly/tests/msgpack/test_sequnpack.pytest_partialdatar      s&   zHMM'	}	%T(^ 
&MM$	}	%T(^ 
&MM$	}	%T(^ 
&MM$	}	%T(^ 
&MM$	}	%T(^ 
&MM$X8+++ 
&	% 
&	% 
&	% 
&	% 
&	%s;   F<F&F3
F?GF#&F03F<?GGc                     t        dd      } | j                  d       | j                         t        d      k(  sJ | j                         t        d      k(  sJ | j                         t        d      k(  sJ | j                         t        d      k(  sJ | j                         t        d      k(  sJ | j                         t        d	      k(  sJ t	        j
                  t              5  | j                          d d d        | j                  d
       | j                  d       d}t        | d      D ]  \  }}|t        |      k(  sJ |dz  } |t        d      k(  sJ y # 1 sw Y   gxY w)N      	read_sizeuse_list   foobar   fr      br
      rs   foos   barr   	foobarbaz)	r   r   unpackordr   r   r   ziplen)r   koes       r   test_foobarr)      s5   !a0HMM)??D	)))??D	)))??D	)))??D	)))??D	)))??D	)))	y	! 
" MM&MM&	AHk*1CF{{	Q + I 
"	!s   ,E##E,c                     t        dd      } | j                  d       | j                         t        d      k(  sJ | j	                          | j                         t        d      k(  sJ | j	                          | j                         t        d      k(  sJ | j	                          t        j                  t              5  | j                          d d d        y # 1 sw Y   y xY w)Nr   r   r   r   r   r   r
   )r   r   r"   r#   skipr   r   r   r   s    r   test_foobar_skipr,   3   s    !a0HMM)??D	)))MMO??D	)))MMO??D	)))MMO	y	! 
"	!	!s   CC%c                  B   t        j                  t              5  t        dd       d d d        t        ddd      } | j	                  d       t        j                  t
              5  | j	                  d       d d d        | j	                  d       t        d	      t        |       k(  sJ | j	                  d
       t        d      t        |       k(  sJ t        d      t        |       k(  sJ t        d      t        |       k(  sJ y # 1 sw Y   xY w# 1 sw Y   xY w)N   r   )r   max_buffer_sizer   )r   r/   r   s   fos   obr   fr   r'   b)r   r   
ValueErrorr   r   r   r#   r   r   s    r   test_maxbuffersizer3   @   s    	z	"1a0 
#!QCHMM%	z	"e 
#MM$s8tH~%%%MM$s8tH~%%%s8tH~%%%s8tH~%%% 
#	" 
#	"s   D	(D	DDc                  >   t        d      } | j                  d       | j                         t        d      k(  sJ | j	                  d      dk(  sJ | j                         t        d      k(  sJ | j                         t        d      k(  sJ t        t        j                  d      d      } | j                         t        d      k(  sJ | j	                  d      dk(  sJ | j                         t        d      k(  sJ | j                         t        d      k(  sJ y )Nr   )r   r   r   s   oobr
   r    )r   r   r"   r#   
read_bytesioBytesIOr   s    r   test_readbytesr8   O   s    !$HMM)??D	)))q!V+++??D	)))??D	))) 

9-;H??D	)))q!V+++??D	)))??D	)))    c                  >   t               } | j                  d       t        |       dk(  sJ t        |       dk(  sJ | j                  d       t        |       dk(  sJ t        |       dk(  sJ | j                  d       t        |       dk(  sJ t        |       dk(  sJ y )Ns   ?!)   ?   ! s   ?)r;   r<   )r<   )r   r   tupler   s    r   test_issue124r?   _   s    zHMM- ?l***?b   MM,?g%%%?b   MM$?g%%%?b   r9   c                     t        j                         } t        d      D cg c]
  }d|z  dz
   }}|t        dd      D cg c]  }d|z   
 c}z  }|dddz  t        t        d            t        d      D ci c]  }|t	        |      |z   c}t        d	      D ci c]  }|t	        |      |z   c}gz  }g }|D ]-  }t        ||        |j                  | j                                / | j                  d
       t        |       }t        ||      D ],  \  }}t        |      }||k(  sJ ||j                         k(  r,J  y c c}w c c}w c c}w c c}w )NA      r   @   s   helloi     
       r   )r6   r7   rangelistbytesr   appendtellseekr   r$   r   )streamimessagesoffsetsmr   r'   m2s           r   test_unpack_tellrS   l   sJ   ZZ\F$)"I.IqQ
IH.E!RL1Lq16L11H4U2Y"'),)QE!HqL),"'),)QE!HqL), H GQv{{}%  KKNHHg&1(^BwwHMMO### ' /1
 	-,s   EE:EE)r6   r   srsly.msgpackr   r   r   srsly.msgpack.exceptionsr   r   r)   r,   r3   r8   r?   rS   r=   r9   r   <module>rV      s7    	  .  .,*,
&* 
!$r9   