
    	                         d dl Z d dlZd dlZd dlmZ d dlmZ  G d de      Z ej                         j                  ej                  e         Zedk(  r# ej                  d      j                  e       yy)	    N)BaseTestCase)	streamingc                   0    e Zd Zd Zd Zd Zd Zd Zd Zy)CachingStreamWrapperTestCasec                     d| _         | j                   t        j                  dz  z  | _        t        j                  | j                         | _        t        j                  | j                        | _        y )Ns
   abcdefghij   )	shortTextioDEFAULT_BUFFER_SIZElongTextBytesIOshortStream
longStream)selfs    @platform/gsutil/third_party/pyasn1/tests/codec/test_streaming.pysetUpz"CachingStreamWrapperTestCase.setUp   sM    &"*@*@1*DE::dnn5**T]]3    c                    t        j                  | j                        }|j                  d       |j	                  d       |j                  d      dk(  sJ |j                  d      dk(  sJ |j                         dk(  sJ y )N            d   er   r   CachingStreamWrapperr   readseektellr   wrappers     r   testReadJustFromCachez2CachingStreamWrapperTestCase.testReadJustFromCache   sn    001A1ABQQ||A$&&&||A$&&&||~"""r   c                     t        j                  | j                        }|j                  d       |j	                  d       |j                  d      dk(  sJ |j                         dk(  sJ y )Nr   r      s   defg   r   r   s     r   testReadFromCacheAndStreamz7CachingStreamWrapperTestCase.testReadFromCacheAndStream   sX    001A1ABQQ||A')))||~"""r   c                     t        j                  | j                        }|j                  d      dk(  sJ |j	                         dk(  sJ y )Nr   s   abcdef)r   r   r   r   r   r   s     r   testReadJustFromStreamz3CachingStreamWrapperTestCase.testReadJustFromStream&   sB    001A1AB||A)+++||~"""r   c                 D   t        j                  | j                        }|j                  t        j
                  dz         }t        |      t        j
                  dz   k(  sJ |j                  d      sJ |j                         dk(  sJ |j                  d      dk(  sJ y )NI   s   abcdefgr   r#   s   abcd)
r   r   r   peekr
   r   len
startswithr   r   )r   r    
read_bytess      r   testPeekz%CachingStreamWrapperTestCase.testPeek+   s    00A\\""8"82"=>
:""8"82"====$$Z000||~"""||A')))r   c                    t        j                  | j                        }|j                  d       |j	                         |_        |j
                  dk(  sJ |j                  t        j                         |j	                         dt        j                  z   k(  sJ |j	                         |_        |j
                  dk(  sJ t        |j                  j                               dk(  sJ y )N
   r   )r   r   r   r   r   markedPositionr
   r   r+   _cachegetvaluer   s     r   testMarkedPositionResetsz5CachingStreamWrapperTestCase.testMarkedPositionResets3   s    00AR!(%%+++ 	R++,||~b&<&<!<<<< ")%%***7>>**,-222r   N)	__name__
__module____qualname__r   r!   r%   r'   r.   r4    r   r   r   r      s     4###
*3r   r   __main__   )	verbosity)r
   sysunittest
tests.baser   pyasn1.codecr   r   
TestLoaderloadTestsFromModulemodulesr5   suiteTextTestRunnerrunr8   r   r   <module>rF      sq    
 
  # "03< 03f 	11#++h2GHzHa(,,U3 r   