O'^c@@s@dZddlmZddlmZdefdYZdS(si kombu.transport.virtual.scheduling ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ Consumer utilities. i(tabsolute_import(tcountt FairCyclecB@s>eZdZedZdZdZdZdZRS(sbConsume from a set of resources, where each resource gets an equal chance to be consumed from.cC@s(||_||_||_d|_dS(Ni(tfunt resourcest predicatetpos(tselfRRR((sD/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/virtual/scheduling.pyt__init__s   cC@sgx`y'|j|j}|jd7_|SWqtk r^d|_|js_|jq_qXqWdS(Nii(RRt IndexErrorR(Rtresource((sD/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/virtual/scheduling.pyt_nexts   cK@swxptdD]b}|j}y|j|||fSWq |jk rn|t|jdkroqoq Xq WdS(Nii(RR RRtlenR(RtkwargsttriedR ((sD/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/virtual/scheduling.pytget"s cC@sdS(N((R((sD/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/virtual/scheduling.pytclose,scC@sdjd|dt|jS(Ns/Rtsize(tformatR R(R((sD/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/virtual/scheduling.pyt__repr__/s ( t__name__t __module__t__doc__t ExceptionRR RRR(((sD/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/virtual/scheduling.pyR s   N(Rt __future__Rt itertoolsRtobjectR(((sD/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/virtual/scheduling.pyts