HEX
Server: Apache/2.4.52 (Ubuntu)
System: Linux spn-python 5.15.0-89-generic #99-Ubuntu SMP Mon Oct 30 20:42:41 UTC 2023 x86_64
User: arjun (1000)
PHP: 8.1.2-1ubuntu2.20
Disabled: NONE
Upload Files
File: //usr/lib/python3/dist-packages/twisted/test/__pycache__/test_tpfile.cpython-310.pyc
o

�b	�@srddlmZddlmZmZddlmZmZddlm	Z	Gdd�dej
�ZGdd�dej
�ZGd	d
�d
e	j
�ZdS)�)�BytesIO)�abstract�protocol)�basic�loopback)�unittestc@seZdZdZdd�ZdS)�BufferingServer�cCs|j|7_dS�N)�buffer)�self�data�r�:/usr/lib/python3/dist-packages/twisted/test/test_tpfile.py�dataReceivedszBufferingServer.dataReceivedN)�__name__�
__module__�__qualname__rrrrrrrsrc@�eZdZdd�Zdd�ZdS)�FileSendingClientcCs
||_dSr
)�f)rrrrr�__init__s
zFileSendingClient.__init__cs4t��}|��j�jdd��}|��fdd��dS)NcS�|Sr
r��xrrr�<lambda>�z2FileSendingClient.connectionMade.<locals>.<lambda>cs
�j��Sr
)�	transport�loseConnection)�r�rrrrs
)r�
FileSender�beginFileTransferrr�addCallback)r�s�drr r�connectionMadesz FileSendingClient.connectionMadeN)rrrrr&rrrrrsrc@r)�FileSenderTestscs<d�t��tt���}t��|�}|����fdd��|S)Ns�xyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabc123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123cs���j��Sr
)�assertEqualrr�r$r�testStrrrr$sz1FileSenderTests.testSendingFile.<locals>.<lambda>)rrrr�loopbackTCPr#)r�cr%rr)r�testSendingFileszFileSenderTests.testSendingFilecCsNt��}t��}d|_td�}|�||dd��}|�|j�|�	|j
d�dS)N�r	cSrr
rrrrrr-rz6FileSenderTests.testSendingEmptyFile.<locals>.<lambda>z0producer unregistered with deferred being called)rr!r�FileDescriptor�	connectedrr"�assertIsNone�producer�
assertTrue�called)r�
fileSender�consumer�	emptyFiler%rrr�testSendingEmptyFile'sz$FileSenderTests.testSendingEmptyFileN)rrrr-r8rrrrr's	r'N)�ior�twisted.internetrr�twisted.protocolsrr�
twisted.trialr�Protocolrr�TestCaser'rrrr�<module>s