hb*SrSSKJr SSKJr SSKJr SSKJr SSK J r J r J r SSK Jr SSKJr SS KJrJrJrJrJr SS KJr "S S \5r\"\5"S S55r"SS\5r"SS\5r"SS\5rg)z" Tests for L{twisted.test.iosim}. ) annotations)Literal) implementer) IPushProducer) ClientFactoryFactoryProtocol)Clock) MemoryReactor)ConnectionCompleter FakeTransportIOPumpconnectconnectedServerAndClient)TestCasec6\rSrSrSrSSjrSSjrSSjrSrg) FakeTransportTestsz Tests for L{FakeTransport}. c [[5S5n[[5S5nURUR[5 URUR[5 UR URUR5 g)zM Each L{FakeTransport} receives a serial number that uniquely identifies it. TFN)r objectassertIsInstanceserialintassertNotEqual)selfabs ^/root/1688_scrapy/alibaba-scraper/venv/lib/python3.13/site-packages/twisted/test/test_iosim.pytest_connectionSerial(FakeTransportTests.test_connectionSerial s` &(D ) &(E * ahh, ahh, AHHahh/c[[5S5nURS5 UR/SQ5 UR SR UR 5S5 g)zT L{FakeTransport.writeSequence} will write a sequence of L{bytes} to the transport. Fa)bcdr!sabcdN)r rwrite writeSequence assertEqualjoinstreamrrs rtest_writeSequence%FakeTransportTests.test_writeSequence+sG &(E *   *+ !((+W5r!c[[5S5nURS5 UR5 URS5 UR SR UR 5S5 g)zp L{FakeTransport.write} will accept writes after transport was closed, but the data will be silently discarded. Fsbeforesafterr!N)r rr'loseConnectionr)r*r+r,s rtest_writeAfterClose'FakeTransportTests.test_writeAfterClose7sS &(E *     !((+Y7r!NreturnNone) __name__ __module__ __qualname____firstlineno____doc__rr-r1__static_attributes__r3r!rrrs 0 6 8r!rc:\rSrSrSrSrS SjrS SjrS SjrSr g) StrictPushProducerDzw An L{IPushProducer} implementation which produces nothing but enforces preconditions on its state transition methods. runningcHURS:Xa [S5eSUlg)Nstoppedz)Cannot stop already-stopped IPushProducer_state ValueErrorrs r stopProducing StrictPushProducer.stopProducingMs! ;;) #HI I r!cdURS:wa[SURS35eSUlg)Nr@z Cannot pause  IPushProducerpausedrCrFs rpauseProducing!StrictPushProducer.pauseProducingRs- ;;) #}T[[MHI I r!cdURS:wa[SURS35eSUlg)NrKzCannot resume rJr@rCrFs rresumeProducing"StrictPushProducer.resumeProducingWs- ;;( "~dkk].IJ J r!)rDNr4) r7r8r9r:r;rDrGrLrOr<r3r!rr>r>Ds F   r!r>c\rSrSrSrSSjrSSjrSSjrSSjrSSjr SSjr SS jr SS jr SS jr SS jrSS jrSSjrSSjrSSjrSSjrSSjrSSjrSSjrSSjrSrg)StrictPushProducerTests]z" Tests for L{StrictPushProducer}. c[5$)zX @return: A new L{StrictPushProducer} which has not been through any state changes. )r>rFs r_initial StrictPushProducerTests._initialbs "##r!c:[5nUR5 U$)z0 @return: A new, stopped L{StrictPushProducer}. )r>rGrproducers r_stopped StrictPushProducerTests._stoppedis&' r!c:[5nUR5 U$)z/ @return: A new, paused L{StrictPushProducer}. )r>rLrXs r_pausedStrictPushProducerTests._pausedqs&'!r!cZ[5nUR5 UR5 U$)zI @return: A new L{StrictPushProducer} which has been paused and resumed. )r>rLrOrXs r_resumed StrictPushProducerTests._resumedys)&'!  "r!c<URURS5 g)z Assert that the given producer is in the stopped state. @param producer: The producer to verify. @type producer: L{StrictPushProducer} rBNr)rDrXs r assertStopped%StrictPushProducerTests.assertStopped )4r!c<URURS5 g)z Assert that the given producer is in the paused state. @param producer: The producer to verify. @type producer: L{StrictPushProducer} rKNrcrXs r assertPaused$StrictPushProducerTests.assertPauseds (3r!c<URURS5 g)z Assert that the given producer is in the running state. @param producer: The producer to verify. @type producer: L{StrictPushProducer} r@NrcrXs r assertRunning%StrictPushProducerTests.assertRunningrfr!c`UR[UR5R5 g)zb L{StrictPushProducer.stopProducing} raises L{ValueError} if called when the producer is stopped. N) assertRaisesrErZrGrFs rtest_stopThenStop)StrictPushProducerTests.test_stopThenStops *dmmo&C&CDr!c`UR[UR5R5 g)zc L{StrictPushProducer.pauseProducing} raises L{ValueError} if called when the producer is stopped. N)rnrErZrLrFs rtest_stopThenPause*StrictPushProducerTests.test_stopThenPauses *dmmo&D&DEr!c`UR[UR5R5 g)zd L{StrictPushProducer.resumeProducing} raises L{ValueError} if called when the producer is stopped. N)rnrErZrOrFs rtest_stopThenResume+StrictPushProducerTests.test_stopThenResumes *dmmo&E&EFr!cfUR5nUR5 URU5 g)zV L{StrictPushProducer} is stopped if C{stopProducing} is called on a paused producer. N)r]rGrdrXs rtest_pauseThenStop*StrictPushProducerTests.test_pauseThenStops) <<>  8$r!cdUR5nUR[UR5 g)z[ L{StrictPushProducer.pauseProducing} raises L{ValueError} if called on a paused producer. N)r]rnrErLrXs rtest_pauseThenPause+StrictPushProducerTests.test_pauseThenPauses% <<> *h&=&=>r!cfUR5nUR5 URU5 g)zX L{StrictPushProducer} is resumed if C{resumeProducing} is called on a paused producer. N)r]rOrkrXs rtest_pauseThenResume,StrictPushProducerTests.test_pauseThenResumes) <<>  " 8$r!cfUR5nUR5 URU5 g)zW L{StrictPushProducer} is stopped if C{stopProducing} is called on a resumed producer. N)r`rGrdrXs rtest_resumeThenStop+StrictPushProducerTests.test_resumeThenStop) ==?  8$r!cfUR5nUR5 URU5 g)zW L{StrictPushProducer} is paused if C{pauseProducing} is called on a resumed producer. N)r`rLrhrXs rtest_resumeThenPause,StrictPushProducerTests.test_resumeThenPause) ==?! (#r!cdUR5nUR[UR5 g)z] L{StrictPushProducer.resumeProducing} raises L{ValueError} if called on a resumed producer. N)r`rnrErOrXs rtest_resumeThenResume-StrictPushProducerTests.test_resumeThenResume% ==? *h&>&>?r!cfUR5nUR5 URU5 g)zV L{StrictPushProducer} is stopped if C{stopProducing} is called in the initial state. N)rUrGrdrXs r test_stop!StrictPushProducerTests.test_stoprr!cfUR5nUR5 URU5 g)zV L{StrictPushProducer} is paused if C{pauseProducing} is called in the initial state. N)rUrLrhrXs r test_pause"StrictPushProducerTests.test_pauserr!cdUR5nUR[UR5 g)zb L{StrictPushProducer} raises L{ValueError} if C{resumeProducing} is called in the initial state. N)rUrnrErOrXs r test_resume#StrictPushProducerTests.test_resumerr!r3N)r5r>)rYr>r5r6r4)r7r8r9r:r;rUrZr]r`rdrhrkrorrrurxr{r~rrrrrrr<r3r!rrRrR]sk$545EFG%?%%$@%$@r!rRc@\rSrSrSrS SjrS SjrS SjrS SjrSr g) IOPumpTestsiz Tests for L{IOPump}. c [5n[USS9n[5n[USS9n[UUUUSS9n[5nUUS.UnUR USS9 UR 5 UR SUR5 g) a Connect a couple protocol/transport pairs to an L{IOPump} and then pump it. Verify that a streaming producer registered with one of the transports does not receive invalid L{IPushProducer} method calls and ends in the right state. @param mode: C{u"server"} to test a producer registered with the server transport. C{u"client"} to test a producer registered with the client transport. T)isServerF)greet)serverclient) streamingr@N)r r rr>registerProducerpumpr)rD) rmode serverProtoserverTransport clientProtoclientTransportrrYvictims r_testStreamingProducer"IOPumpTests._testStreamingProducersj ' dCj ' eD      &'%%   D9  HOO4r!c"URSS9 g)z L{IOPump.pump} does not call C{resumeProducing} on a L{IPushProducer} (stream producer) registered with the server transport. rrNrrFs rtest_serverStreamingProducer(IOPumpTests.test_serverStreamingProducer) ###2r!c"URSS9 g)z L{IOPump.pump} does not call C{resumeProducing} on a L{IPushProducer} (stream producer) registered with the client transport. rrNrrFs rtest_clientStreamingProducer(IOPumpTests.test_clientStreamingProducer0rr!c^/m[5n[[[US9u p#URSU4Sj5 UR T5 UR 5 UR T5 g)z5 L{IOPump.pump} advances time in the given L{Clock}. )clockrc&>TRS5$)NT)append) time_passedsr/IOPumpTests.test_timeAdvances..>s;#5#5d#;r!N)r rr callLater assertFalser assertTrue)rr_rrs @rtest_timeAdvancesIOPumpTests.test_timeAdvances7sU -hN 1 ;< %   $r!r3N)rzLiteral['server', 'client']r5r6r4) r7r8r9r:r;rrrrr<r3r!rrrs!5F33 %r!rc,\rSrSrSrSSjrSSjrSrg)ConnectionCompleterTestsiDzf L{ConnectionCompleter} can connect a connecting client and a listening server in a L{MemoryReactor}. cj[[55nURUR5S5 g)zd When no connection for its reactor is pending, L{ConnectionCompleter.succeedOnce} returns C{None}. N)r r assertIs succeedOnce)rccs rtest_noConnection*ConnectionCompleterTests.test_noConnectionJs% ! 1 bnn&-r!c [5nURS[R"[55 UR SS[ R"[55 [U5nURUR5[5 g)zw When a connection to a matched host and port is pending, L{ConnectionCompleter} returns an L{IOPump} connecting them. Pz 127.0.0.1N) r listenTCPr forProtocolr connectTCPrr rrr)rmemrs rtest_someConnection,ConnectionCompleterTests.test_someConnectionRs` o b'--h78 {B (A(A((KL  % bnn.7r!r3Nr4)r7r8r9r:r;rrr<r3r!rrrDs . 8r!rN)r; __future__rtypingrzope.interfacertwisted.internet.interfacesrtwisted.internet.protocolrrr twisted.internet.taskr twisted.internet.testingr twisted.test.iosimr r rrrtwisted.trial.unittestrrr>rRrrr3r!rrs#&5FF'2,&8&8R ]   0a@ha@H@%(@%F8x8r!