ó O'—^c@@siddlmZddlmZddlmZdefd„ƒYZd„Zdefd„ƒYZ d S( i(tabsolute_import(t FairCycle(tCasetMyEmptycB@seZRS((t__name__t __module__(((sO/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_scheduling.pyRscC@s1g}x$t|ƒD]}|j|ƒƒqW|S(N(trangetappend(tfuntntrti((sO/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_scheduling.pytconsume sttest_FairCyclecB@s,eZd„Zd„Zd„Zd„ZRS(cC@sıdddddg}dd„}t||tƒ}x>tt|ƒƒD]*}|j|jƒ||||fƒqFWx>tt|ƒƒD]*}|j|jƒ||||fƒq‡WdS(NtatbtctdtecS@s|S(N((R ttimeout((sO/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_scheduling.pytechos(tNoneRRRtlent assertEqualtget(tselft resourcesRtcycleR ((sO/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_scheduling.pyt test_cycles cC@sÔdddddg}d„}t||tƒ}|jt|jt|ƒƒdd d d d gƒ|jt|jt|ƒƒd ddddgƒt|ddgtƒ}|jtƒt|jdƒWdQXdS(NRRRRRcS@s|dkrt|ƒ‚n|S(NR(R(R ((sO/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_scheduling.pyR's i(RR(RR(RR(RR(RR(RR(RR(RR(RR(RR(RRRR RRt assertRaises(RRRRtcycle2((sO/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_scheduling.pyttest_cycle_breaks$s     cC@s?tdgtƒ}d|_|jtƒ|jƒWdQXdS(Ni (RRRtposRt_next(RR((sO/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_scheduling.pyttest_cycle_no_resources;s cC@s/|jttd„dddgtƒƒƒdS(NcS@s|S(N((tx((sO/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_scheduling.pytCtiii(t assertTruetreprRR(R((sO/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_scheduling.pyt test__repr__Bs(RRRRR"R((((sO/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_scheduling.pyR s   N( t __future__Rt"kombu.transport.virtual.schedulingRtkombu.tests.caseRt ExceptionRR R (((sO/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_scheduling.pyts