
    h                         S SK Jr  S SKJrJrJr  S SKJrJr  S SK	J
r
   " S S\R                  5      r " S S\R                  5      r " S	 S
\
R                  5      rg)    )BytesIO)abstractdeferprotocol)basicloopback)unittestc                   *    \ rS rSrSrS\SS4S jrSrg)BufferingServer       datareturnNc                 .    U =R                   U-  sl         g N)buffer)selfr   s     _/root/1688_scrapy/alibaba-scraper/venv/lib/python3.13/site-packages/twisted/test/test_tpfile.pydataReceivedBufferingServer.dataReceived   s    tr    )__name__
__module____qualname____firstlineno__r   bytesr   __static_attributes__r   r   r   r   r      s    F 4 r   r   c                   0    \ rS rSrS\SS4S jrSS jrSrg)	FileSendingClient   fr   Nc                     Xl         g r   r!   )r   r!   s     r   __init__FileSendingClient.__init__   s    r   c                    ^  T R                   c   e[        R                  " 5       nUR                  T R                  T R                   S 5      nUR                  U 4S j5        g )Nc                     U $ r   r   xs    r   <lambda>2FileSendingClient.connectionMade.<locals>.<lambda>   s    !r   c                 8   > TR                   R                  5       $ r   )	transportloseConnection)rr   s    r   r*   r+      s     = = ?r   )r-   r   
FileSenderbeginFileTransferr!   addCallback)r   sds   `  r   connectionMade FileSendingClient.connectionMade   sJ    ~~)))D	?@r   r#   r   N)r   r   r   r   r   r$   r5   r   r   r   r   r   r      s    ' d Ar   r   c                   F    \ rS rSrS\R
                  S   4S jrSS jrSrg)FileSenderTests   r   Nc                    ^ ^^ Sm[        5       m[        [        T5      5      n[        R                  " TU5      nS[
        SS 4UU U4S jjnUR                  U5      $ )Ns  xyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabc123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123r)   r   c                 >   > TR                  TR                  T5        g r   )assertEqualr   )r)   r3   r   testStrs    r   callback1FileSenderTests.testSendingFile.<locals>.callback&   s    QXXw/r   )r   r   r   r   loopbackTCPobjectr2   )r   cr4   r?   r3   r>   s   `   @@r   testSendingFileFileSenderTests.testSendingFile   sZ    <gg./"*"6"6q!"<	0 	04 	0 	0 }}X&&r   c                    [         R                  " 5       n[        R                  " 5       nSUl        [        S5      nUR                  X2S 5      nU R                  UR                  5        U R                  UR                  S5        g )N   r   c                     U $ r   r   r(   s    r   r*   6FileSenderTests.testSendingEmptyFile.<locals>.<lambda>1   s    r   z0producer unregistered with deferred being called)r   r0   r   FileDescriptor	connectedr   r1   assertIsNoneproducer
assertTruecalled)r   
fileSenderconsumer	emptyFiler4   s        r   testSendingEmptyFile$FileSenderTests.testSendingEmptyFile+   sl    %%'
**,CL	((kJ 	(++, 	"TUr   r   r7   )	r   r   r   r   r   DeferredrD   rS   r   r   r   r   r9   r9      s    
'!5 
'Vr   r9   N)ior   twisted.internetr   r   r   twisted.protocolsr   r   twisted.trialr	   Protocolr   r   TestCaser9   r   r   r   <module>r\      sP   
  6 6 - "h'' A)) AVh'' Vr   