+
    Dfj                         ^ RI Ht ^ RIHtHtHt ^ RIHtHt ^ RI	H
t
  ! R R]P                  4      t ! R R]P                  4      t ! R	 R
]
P                  4      tR# )    BytesIO)abstractdeferprotocol)basicloopback)unittestc                   6   a  ] tR t^t o RtV 3R lR ltRtV tR# )BufferingServer    c                $   < V ^8  d   QhRS[ RR/# )   datareturnN)bytes)format__classdict__s   ":/usr/lib/python3/dist-packages/twisted/test/test_tpfile.py__annotate__BufferingServer.__annotate__   s       4 r   c                8    V ;P                   V,          un         R # N)buffer)selfr   s   &&r   dataReceivedBufferingServer.dataReceived   s    tr    N)__name__
__module____qualname____firstlineno__r   r   __static_attributes____classdictcell__r   s   @r   r   r      s     F r   r   c                   D   a  ] tR t^t o V 3R lR ltV 3R lR ltRtV tR# )FileSendingClientc                $   < V ^8  d   QhRS[ RR/# )r   fr   Nr   )r   r   s   "r   r   FileSendingClient.__annotate__   s      ' d r   c                    Wn         R # r   r)   )r   r)   s   &&r   __init__FileSendingClient.__init__   s    r   c                   < V ^8  d   QhRR/# r   r   Nr   )r   r   s   "r   r   r*      s     A A Ar   c                   a  S P                   f   Q h\        P                  ! 4       pVP                  S P                  S P                   R 4      pVP                  V 3R l4       R # )Nc                     V # r   r   xs   &r   <lambda>2FileSendingClient.connectionMade.<locals>.<lambda>   s    !r   c                 8   < SP                   P                  4       # r   )	transportloseConnection)rr   s   &r   r5   r6      s     = = ?r   )r8   r   
FileSenderbeginFileTransferr)   addCallback)r   sds   f  r   connectionMade FileSendingClient.connectionMade   sJ    ~~)))D	?@r   r,   N)r   r    r!   r"   r-   r@   r#   r$   r%   s   @r   r'   r'      s      A Ar   r'   c                   D   a  ] tR t^t o V 3R lR ltV 3R lR ltRtV tR# )FileSenderTestsc                B   < V ^8  d   QhRS[ P                  R,          /# r0   )r   Deferred)r   r   s   "r   r   FileSenderTests.__annotate__   s     
' 
'!5 
'r   c                   a aa Ro\        4       o\        \        S4      4      p\        P                  ! SV4      pR VV V3R llpVP                  V4      # )s   xyzc                (    V ^8  d   QhR\         RR/# )r   r4   r   N)object)r   s   "r   r   5FileSenderTests.testSendingFile.<locals>.__annotate__&   s     	0 	0 	04 	0r   c                 @   < SP                  SP                  S4       R # r   )assertEqualr   )r4   r>   r   testStrs   &r   callback1FileSenderTests.testSendingFile.<locals>.callback&   s    QXXw/r   s  xyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabc123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123)r   r'   r   r	   loopbackTCPr=   )r   cr?   rN   r>   rM   s   f   @@r   testSendingFileFileSenderTests.testSendingFile   sL    <gg./"*"6"6q!"<	0 	0 }}X&&r   c                   < V ^8  d   QhRR/# r0   r   )r   r   s   "r   r   rF   +   s     V Vd Vr   c                   \         P                  ! 4       p\        P                  ! 4       p^Vn        \        R4      pVP                  W2R 4      pV P                  VP                  4       V P                  VP                  R4       R# )   r   c                     V # r   r   r3   s   &r   r5   6FileSenderTests.testSendingEmptyFile.<locals>.<lambda>1   s    r   z0producer unregistered with deferred being calledN)r   r;   r   FileDescriptor	connectedr   r<   assertIsNoneproducer
assertTruecalled)r   
fileSenderconsumer	emptyFiler?   s   &    r   testSendingEmptyFile$FileSenderTests.testSendingEmptyFile+   sl    %%'
**,CL	((kJ 	(++, 	"TUr   r   N)r   r    r!   r"   rR   rb   r#   r$   r%   s   @r   rC   rC      s     
' 
'V Vr   rC   N)ior   twisted.internetr   r   r   twisted.protocolsr   r	   twisted.trialr
   Protocolr   r'   TestCaserC   r   r   r   <module>rj      sP   
  6 6 - "h'' A)) AVh'' Vr   