֛hA2SrSSKJr SSKJr SSKJr SSKJr SSK J r SSK J r J r JrJrJrJrJrJrJr SSKJrJr SS KJrJrJrJr SS KJr SS KJ r "S S \ 5r!"SS\ 5r""SS5r#"SS\ 5r$"SS\5r%"SS\ 5r&g)z( Tests for L{twisted.internet.testing}. ) annotations)Callable) verifyObject)Protocol) IPv4Address) IAddress IConnector IConsumerIListeningPort IPushProducer IReactorSSL IReactorTCP IReactorUNIX ITransport) ClientFactoryFactory) MemoryReactorNonStreamingProducerRaisingMemoryReactorStringTransport)namedAny)TestCasec\rSrSrSrSSjrSSjrSSjrSSjrSSjr SSjr SS jr SS jr SS jr SS jrSS jrSSjrSSjrSSjrSSjrSSjrSSjrSSjrSSjrSrg)StringTransportTests&z8 Tests for L{twisted.internet.testing.StringTransport}. c"[5UlgN)r transportselfs fC:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\twisted/internet/test/test_testing.pysetUpStringTransportTests.setUp+s (*cUR[[UR55 UR[[UR55 UR[[ UR55 g)zY L{StringTransport} instances provide L{ITransport}, L{IPushProducer}, and L{IConsumer}. N) assertTruerrrr r rs r!test_interfaces$StringTransportTests.test_interfaces.sI  Z@A  ]DNNCD  Y?@r$c[5n[5nURRX5 URURRU5 URURR U5 g)zb L{StringTransport.registerProducer} records the arguments supplied to it as instance attributes. N)objectrregisterProducerassertIsproducer streamingr r-r.s r!test_registerProducer*StringTransportTests.test_registerProducer7sT 8H  ''< dnn--x8 dnn.. :r$cN[5nURRUS5 UR[URR[5S5 UR URR U5 URURR5 g)za L{StringTransport.registerProducer} raises L{RuntimeError} if a producer is already registered. TFN) r*rr+ assertRaises RuntimeErrorr,r-r&r.)r r-s r!test_disallowedRegisterProducer4StringTransportTests.test_disallowedRegisterProducerBsr 8 ''$7  $..9968U  dnn--x8 001r$c[5n[5nURRUS5 URR5 UR URR 5 URRUS5 UR URR U5 URURR5 g)z L{StringTransport.unregisterProducer} causes the transport to forget about the registered producer and makes it possible to register a new one. FTN) r*rr+unregisterProducer assertIsNoner-r,r&r.)r oldProducer newProducers r!test_unregisterProducer,StringTransportTests.test_unregisterProducerOs h h  '' U; ))+ $..112 '' T: dnn--{; 001r$cXUR[URR5 g)zh L{StringTransport.unregisterProducer} raises L{RuntimeError} if called when no producer is registered. N)r3r4rr8rs r!test_invalidUnregisterProducer3StringTransportTests.test_invalidUnregisterProducer^s ,(I(IJr$cPURURRS5 g)z? L{StringTransport.producerState} is initially C{'producing'}. producingN) assertEqualr producerStaters r!test_initialProducerState.StringTransportTests.test_initialProducerStatees 55{Cr$cURR5 URURRS5 g)za L{StringTransport.pauseProducing} changes the C{producerState} of the transport to C{'paused'}. pausedN)rpauseProducingrCrDrs r!test_pauseProducing(StringTransportTests.test_pauseProducingks. %%' 55x@r$cURR5 URR5 URURRS5 g)ze L{StringTransport.resumeProducing} changes the C{producerState} of the transport to C{'producing'}. rBN)rrIresumeProducingrCrDrs r!test_resumeProducing)StringTransportTests.test_resumeProducingss> %%' &&( 55{Cr$cURR5 URURRS5 g)zc L{StringTransport.stopProducing} changes the C{'producerState'} of the transport to C{'stopped'}. stoppedN)r stopProducingrCrDrs r!test_stopProducing'StringTransportTests.test_stopProducing|s. $$& 55yAr$cURR5 UR[URR5 g)z] L{StringTransport.pauseProducing} raises L{RuntimeError} if the transport has been stopped. N)rrRr3r4rIrs r! test_stoppedTransportCannotPause5StringTransportTests.test_stoppedTransportCannotPauses. $$& ,(E(EFr$cURR5 UR[URR5 g)z^ L{StringTransport.resumeProducing} raises L{RuntimeError} if the transport has been stopped. N)rrRr3r4rMrs r!!test_stoppedTransportCannotResume6StringTransportTests.test_stoppedTransportCannotResumes. $$& ,(F(FGr$cURR5 UR[URR5 g)zb L{StringTransport.pauseProducing} raises L{RuntimeError} if the transport is being disconnected. N)rloseConnectionr3r4rIrs r!&test_disconnectingTransportCannotPause;StringTransportTests.test_disconnectingTransportCannotPauses. %%' ,(E(EFr$cURR5 UR[URR5 g)zc L{StringTransport.resumeProducing} raises L{RuntimeError} if the transport is being disconnected. N)rr\r3r4rMrs r!'test_disconnectingTransportCannotResume2r$c0[5nURSS[55URSS[5S54Hkn[ [ U5 UR 5n[ [U5 URURS5 URURS5 Mm URS[55n[ [ U5 UR 5n[ [U5 URURS5 g)z L{MemoryReactor.connectTCP}, L{MemoryReactor.connectSSL}, and L{MemoryReactor.connectUNIX} will return an L{IConnector} whose C{getDestination} method returns an L{IAddress} with attributes which reflect the values passed. ztest.example.comi Ns /fake/path) r connectTCPr connectSSLrr getDestinationrrChostport connectUNIXname)r r connectorrjs r!test_connectDestination$ReactorTests.test_connectDestinations&  $ $%7} O  $ $%7}PT U I Y /..0G 7 +   W\\+= >   W\\4 0 "--m]_M Z+**,Xw' }5r$c,[5nURS[55URS[5S54Hkn[ [ U5 UR 5n[ [U5 URURS5 URURS5 Mm URS[55n[ [ U5 UR 5n[ [U5 URURS5 g)a^ L{MemoryReactor.listenTCP}, L{MemoryReactor.listenSSL} and L{MemoryReactor.listenUNIX} will return an L{IListeningPort} whose C{getHost} method returns an L{IAddress}; C{listenTCP} and C{listenSSL} will have a default host of C{'0.0.0.0'}, and a port that reflects the value passed, and C{listenUNIX} will have a name that reflects the path passed. i2 Nz0.0.0.0s/path/to/socket) r listenTCPr listenSSLrr rhrrCrr listenUNIXr)r rrrjs r!test_listenDefaultHost#ReactorTests.test_listenDefaultHosts&  # #D') 4  # #D')T : D  .llnG 7 +   W\\9 5   W\\4 0 ''(:GIF^T*,,.Xw' '9:r$c[5n[5nURU5 URU5 URUR 5U/5 UR U5 URUR 5/5 g)z. Adding, removing, and listing readers works. N)r*r addReaderrC getReaders removeReader)r readerreactors r! test_readersReactorTests.test_readersp/&!&! ++-x8V$ ++-r2r$c[5n[5nURU5 URU5 URUR 5U/5 UR U5 URUR 5/5 g)z. Adding, removing, and listing writers works. N)r*r addWriterrC getWriters removeWriter)r writerrs r! test_writersReactorTests.test_writers'rr$rNrz) r}r~rrrrrrrrrrrr$r!rrs%236.;23 3r$rc@\rSrSrSrS SjrS SjrS SjrS SjrSr g) TestConsumeri8zH A very basic test consumer for use with the NonStreamingProducerTests. c./UlSUlSUlgr)writesr-producerStreamingrs r!__init__TestConsumer.__init__=s#% $ .2r$cXlX lg)z Registers a single producer with this consumer. Just keeps track of it. @param producer: The producer to register. @param streaming: Whether the producer is a streaming one or not. Nr-rr/s r!r+TestConsumer.registerProducerBs! !*r$c SUlSUlg)z3 Forget the producer we had previously registered. Nrrs r!r8TestConsumer.unregisterProducerLs !%r$c:URRU5 g)zb Some data was written to the consumer: stores it for later use. @param data: The data to write. N)rappend)r datas r!writeTestConsumer.writeSs 4 r$)r-rrNrz)r-r*r.boolr{r|)rbytesr{r|) r}r~rrrrr+r8rrrr$r!rr8s3 +&!r$rc,\rSrSrSrSSjrSSjrSrg)NonStreamingProducerTestsi\z> Tests for the L{NonStreamingProducer} to validate behaviour. c^[5n[U5nURUS5 URURU5 URUR U5 UR UR5 [S5HnUR5 M /SQnURUR5 URUR5 URUR 5 URURU5 UR[UR5 g)zw When the L{NonStreamingProducer} has resumeProducing called 10 times, it writes the counter each time and then fails. F ) 0123456789N)rrr+r,r-consumerrcrrangerMr9rCrr3r4)r rr-_expectedWritess r!test_producesOnly10Times2NonStreamingProducerTests.test_producesOnly10Timesas  >'1!!(E2 h''2 h''2 334rA  $ $ &V (++, (445 (++, .9 ,(@(@Ar$c[5n[U5nURUS5 UR5 UR [ UR 5 g)zJ When the L{NonStreamingProducer} is paused, it raises a L{RuntimeError}. FN)rrr+rMr3r4rI)r rr-s r!test_cannotPauseProduction4NonStreamingProducerTests.test_cannotPauseProduction{sI  >'1!!(E2   " ,(?(?@r$rNrz)r}r~rrrrrrrr$r!rr\sB4 Ar$rc(\rSrSr\SSj5rSrg) _SupportsNameicgrrrs r!r}_SupportsName.__name__s r$rN)r{str)r}r~rrpropertyrrr$r!rrs   r$rc\rSrSrSrSSjrSSjrSSjrSSjrSSjr SSjr SS jr SS jr SS jr SS jrSS jrSSjrSSjrSSjrSSjrSrg)DeprecationTestsiz0 Deprecations in L{twisted.test.proto_helpers}. cSUR3nURU/5nUR[USS5 URS[ U55 UR X4SS5 UR U[U55 g)Nztwisted.internet.testing.rcategorymessage)r} flushWarningsrCDeprecationWarninglenassertInr,r)r testobjnew_pathwarningss r!helperDeprecationTests.helpersz.s||n=%%tf- +Xa[-DE CM* h I 67 c8H-.r$cHSSKJn URURU5 g)Nr)AccumulatingProtocol)twisted.test.proto_helpersrrtest_accumulatingProtocol)r rs r!r*DeprecationTests.test_accumulatingProtocolC D224HIr$cHSSKJn URURU5 g)Nr)LineSendingProtocol)rrrtest_lineSendingProtocol)r rs r!r)DeprecationTests.test_lineSendingProtocolsB D113FGr$cHSSKJn URURU5 g)Nr)FakeDatagramTransport)rrrtest_fakeDatagramTransport)r rs r!r+DeprecationTests.test_fakeDatagramTransportsD D335JKr$cHSSKJn URURU5 g)Nr)r)rrrtest_stringTransport)r rs r!r%DeprecationTests.test_stringTransports> D--?r$cHSSKJn URURU5 g)Nr) StringTransportWithDisconnection)rrr%test_stringTransportWithDisconnection)r rs r!r6DeprecationTests.test_stringTransportWithDisconnectionsO  6 68X r$cHSSKJn URURU5 g)Nr)StringIOWithoutClosing)rrrtest_stringIOWithoutClosing)r rs r!r,DeprecationTests.test_stringIOWithoutClosingsE D446LMr$cHSSKJn URURU5 g)Nr)_FakeConnector)rr rtest__fakeConnector)r r s r!r $DeprecationTests.test__fakeConnectors= D,,n=r$cHSSKJn URURU5 g)Nr) _FakePort)rrrtest__fakePort)r rs r!rDeprecationTests.test__fakePorts8 D''3r$cHSSKJn URURU5 g)Nr)r)rrrtest_memoryReactor)r rs r!r#DeprecationTests.test_memoryReactors< D++];r$cHSSKJn URURU5 g)Nr)MemoryReactorClock)rrrtest_memoryReactorClock)r rs r!r(DeprecationTests.test_memoryReactorClocksA D002DEr$cHSSKJn URURU5 g)Nr)r)rrrtest_raisingMemoryReactor)r rs r!r*DeprecationTests.test_raisingMemoryReactorrr$cHSSKJn URURU5 g)Nr)r)rrrtest_nonStreamingProducer)r rs r!r*DeprecationTests.test_nonStreamingProducerrr$cHSSKJn URURU5 g)Nr)waitUntilAllDisconnected)rrrtest_waitUntilAllDisconnected)r rs r!r .DeprecationTests.test_waitUntilAllDisconnectedsG D668PQr$cHSSKJn URURU5 g)Nr)EventLoggingObserver)rr#rtest_eventLoggingObserver)r r#s r!r$*DeprecationTests.test_eventLoggingObserverrr$rN)rzCallable[..., object]rrr{r|rz)r}r~rrrrrrrrrrr rrrrrr r$rrr$r!rrs\/J H L @  N > 4 < F J J R Jr$rN)'r __future__rtypingrzope.interface.verifyrtyping_extensionsrtwisted.internet.addressrtwisted.internet.interfacesrr r r r r rrrtwisted.internet.protocolrrtwisted.internet.testingrrrrtwisted.python.reflectrtwisted.trial.unittestrrrrrrrrr$r!r0s#.&0   = ,+e48e4Pg38g3T!!!!H+A+A\ H SJxSJr$