
    	                         S SK r S SKrS SKrS SKJr  S SKJr   " S S\5      r\R                  " 5       R                  \R                  \   5      r\S:X  a   \R                  " SS9R                  \5        gg)	    N)BaseTestCase)	streamingc                   8    \ rS rSrS rS rS rS rS rS r	Sr
g	)
CachingStreamWrapperTestCase   c                     SU l         U R                   [        R                  S-  -  U l        [        R                  " U R                   5      U l        [        R                  " U R                  5      U l        g )Ns
   abcdefghij   )	shortTextioDEFAULT_BUFFER_SIZElongTextBytesIOshortStream
longStream)selfs    @platform/gsutil/third_party/pyasn1/tests/codec/test_streaming.pysetUp"CachingStreamWrapperTestCase.setUp   sM    &"*@*@1*DE::dnn5**T]]3    c                    [         R                  " U R                  5      nUR                  S5        UR	                  S5        UR                  S5      S:X  d   eUR                  S5      S:X  d   eUR                  5       S:X  d   eg )N            d   er	   r   CachingStreamWrapperr   readseektellr   wrappers     r   testReadJustFromCache2CachingStreamWrapperTestCase.testReadJustFromCache   sn    001A1ABQQ||A$&&&||A$&&&||~"""r   c                     [         R                  " U R                  5      nUR                  S5        UR	                  S5        UR                  S5      S:X  d   eUR                  5       S:X  d   eg )Nr   r      s   defg   r   r!   s     r   testReadFromCacheAndStream7CachingStreamWrapperTestCase.testReadFromCacheAndStream   sX    001A1ABQQ||A')))||~"""r   c                     [         R                  " U R                  5      nUR                  S5      S:X  d   eUR	                  5       S:X  d   eg )Nr   s   abcdef)r   r   r   r   r    r!   s     r   testReadJustFromStream3CachingStreamWrapperTestCase.testReadJustFromStream&   sB    001A1AB||A)+++||~"""r   c                 V   [         R                  " U R                  5      nUR                  [        R
                  S-   5      n[        U5      [        R
                  S-   :X  d   eUR                  S5      (       d   eUR                  5       S:X  d   eUR                  S5      S:X  d   eg )NI   s   abcdefgr   r&   s   abcd)
r   r   r   peekr   r   len
startswithr    r   )r   r"   
read_bytess      r   testPeek%CachingStreamWrapperTestCase.testPeek+   s    00A\\""8"82"=>
:""8"82"====$$Z0000||~"""||A')))r   c                    [         R                  " U R                  5      nUR                  S5        UR	                  5       Ul        UR
                  S:X  d   eUR                  [        R                  5        UR	                  5       S[        R                  -   :X  d   eUR	                  5       Ul        UR
                  S:X  d   e[        UR                  R                  5       5      S:X  d   eg )N
   r   )r   r   r   r   r    markedPositionr   r   r0   _cachegetvaluer!   s     r   testMarkedPositionResets5CachingStreamWrapperTestCase.testMarkedPositionResets3   s    00AR!(%%+++ 	R++,||~b&<&<!<<<< ")%%***7>>**,-222r   )r   r   r   r
   N)__name__
__module____qualname____firstlineno__r   r#   r(   r+   r3   r:   __static_attributes__ r   r   r   r      s     4###
*3r   r   __main__   )	verbosity)r   sysunittest
tests.baser   pyasn1.codecr   r   
TestLoaderloadTestsFromModulemodulesr<   suiteTextTestRunnerrunrA   r   r   <module>rO      sm    
 
  # "03< 03f 	11#++h2GHza(,,U3 r   