
    i0                     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    s/var/www/vps2.regionflexible.com/Desarrollo/venv/lib/python3.12/site-packages/srsly/tests/msgpack/test_sequnpack.pytest_partialdatar      sI   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)      sA   !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	" 11a01!QCHMM%	z	" eMM$s8tH~%%%MM$s8tH~%%%s8tH~%%%s8tH~%%%1 1 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   sG   ZZ\F$)"I.qQ
.H.E!RL1q16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   