ϪfddlmZddlmZmZmZddlmZmZddl m Z GddejZ GddejZ Gd d e jZy ) )BytesIO)abstractdeferprotocol)basicloopback)unittestc eZdZdZdeddfdZy)BufferingServerdatareturnNc.|xj|z c_yN)buffer)selfr s :/usr/lib/python3/dist-packages/twisted/test/test_tpfile.py dataReceivedzBufferingServer.dataReceiveds t r )__name__ __module__ __qualname__rbytesrr rr r s F4r r c$eZdZdeddfdZddZy)FileSendingClientfrNc||_yr)r)rrs r__init__zFileSendingClient.__init__s r cjJtj}|jjjd}|j fdy)Nc|Srrxs rz2FileSendingClient.connectionMade..s!r c8jjSr) transportloseConnection)rrs rr#z2FileSendingClient.connectionMade..s = = ?r )r%r FileSenderbeginFileTransferr addCallback)rsds` rconnectionMadez FileSendingClient.connectionMadesJ~~)))       D ?@r rN)rrrrrr-rr rrrs'dAr rc:eZdZdejdfdZddZy)FileSenderTestsrNcdttt}tj|}dt ddffd }|j |S)Nsxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzxyzabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabcabc123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123123r"rc>jjyr) assertEqualr)r"r+rtestStrs rcallbackz1FileSenderTests.testSendingFile..callback&s   QXXw /r )r rrr loopbackTCPobjectr*)rcr,r5r+r4s` @@rtestSendingFilezFileSenderTests.testSendingFilesU<   gg. /"*"6"6q!"< 0 04 0}}X&&r ctj}tj}d|_t d}|j ||d}|j|j|j|jdy)Nr c|Srrr!s rr#z6FileSenderTests.testSendingEmptyFile..1sr z0producer unregistered with deferred being called) rr(rFileDescriptor connectedrr) assertIsNoneproducer assertTruecalled)r fileSenderconsumer emptyFiler,s rtestSendingEmptyFilez$FileSenderTests.testSendingEmptyFile+sn%%' **,CL  ( (Hk J (++, "TUr r.)rrrrDeferredr9rFrr rr0r0s '!5 ' Vr r0N)iortwisted.internetrrrtwisted.protocolsrr twisted.trialr Protocolr rTestCaser0rr rrNsP 66-"h''A))AVh''Vr