YfCRdZddlmZddlmZddlmZmZmZGddeZ dS) z( Tests for L{twisted._threads._memory}. ) verifyObject)SynchronousTestCase) AlreadyQuitIWorkercreateMemoryWorkerc*eZdZdZddZddZddZdS)MemoryWorkerTestsz$ Tests for L{MemoryWorker}. returnNct\}}tt|g|fd|fd|g||d|dg||d|ddgdS)z L{createMemoryWorker} creates an L{IWorker} and a callable that can perform work on it. The performer returns C{True} if it accomplished useful work. c.dS)NappenddonesS/var/www/html/env/lib/python3.11/site-packages/twisted/_threads/test/test_memory.pyz?MemoryWorkerTests.test_createWorkerAndPerform..$++a..c.dS)Nrrsrrz?MemoryWorkerTests.test_createWorkerAndPerform..rrTrrN)rrrdo assertEqual)selfworker performerrs @rtest_createWorkerAndPerformz-MemoryWorkerTests.test_createWorkerAndPerforms /00 Wf%%% (((())) (((())) r""" d+++ s### d+++ 1v&&&&&rct\}}gdfd }||||t|j||t|j||dg||ddS)a Calling C{quit} on the worker returned by L{createMemoryWorker} causes its C{do} and C{quit} methods to raise L{AlreadyQuit}; its C{perform} callable will start raising L{AlreadyQuit} when the work already provided to C{do} has been exhausted. r Nc2ddS)NrrsrmoreWorkz2MemoryWorkerTests.test_quitQuits..moreWork.s KKNNNNNrr!Fr N)rrquit assertRaisesrr)rrrr"rs @rtest_quitQuitsz MemoryWorkerTests.test_quitQuits$s/00         (  +vy(;;; +v{333  s### e,,,,,rcdt\}}||ddS)z The C{perform} callable returned by L{createMemoryWorker} will return no result when there's no work to do yet. Since there is no work to do, the performer returns C{False}. FN)rr)rrrs rtest_performWhenNothingToDoYetz0MemoryWorkerTests.test_performWhenNothingToDoYet9s6 /00  e,,,,,rr#)__name__ __module__ __qualname____doc__rr&r(rrr r sZ''''"----*------rr N) r,zope.interface.verifyrtwisted.trial.unittestrrrrr r-rrr1s/.....66666677777777772-2-2-2-2-+2-2-2-2-2-r