+
    üÐ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œð 	0 4ñ 	0r   c                 ó@   <€ SP                  SP                  S4       R # r   )ÚassertEqualr   )r4   r>   r   ÚtestStrs   &€€€r   ÚcallbackÚ1FileSenderTests.testSendingFile.<locals>.callback&   s   ø€ Ø×Ñ˜QŸX™X wÖ/r   s„  xyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabc123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123)r   r'   r   r	   ÚloopbackTCPr=   )r   Úcr?   rN   r>   rM   s   f   @@r   ÚtestSendingFileÚFileSenderTests.testSendingFile   sL   ú€ Ø<ˆÜÓˆÜœg gÓ.Ó/ˆä"*×"6Ò"6°q¸!Ó"<ˆ÷	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   € Ü×%Ò%Ó'ˆ
Ü×*Ò*Ó,ˆØˆÔÜ˜C“Lˆ	à×(Ñ(¨¹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   