³ò OÉcIc@s}dZddklZddkZddkZddkZddkZddd„ƒYZeieƒdd d„ƒYZ dS( s=Define some lazy data structures and functions acting on themiÿÿÿÿ(t generatorsNtItercBs’eZdZd„Zd„Zd„Zd„Zd„Zd„Zdd„d„Z d „Z d „Z d „Z d „Zd „Zddd„ZRS(s:Hold static methods for the manipulation of lazy iteratorsccs+x$|D]}||ƒo |VqqWdS(s5Like filter in a lazy functional programming languageN((t predicatetiteratorti((s6/var/lib/python-support/python2.5/rdiff_backup/lazy.pytfilters ccs x|D]}||ƒVqWdS(s2Like map in a lazy functional programming languageN((tfunctionRR((s6/var/lib/python-support/python2.5/rdiff_backup/lazy.pytmap#scCsx|D]}||ƒqWdS(s(Run function on each element in iteratorN((RRR((s6/var/lib/python-support/python2.5/rdiff_backup/lazy.pytforeach'scgs+x$|D]}x|D] }|VqWqWdS(sLazily concatenate iteratorsN((titerstiterR((s6/var/lib/python-support/python2.5/rdiff_backup/lazy.pytcat+s ccs+x$|D]}x|D] }|VqWqWdS(s6Lazily concatenate iterators, iterated by big iteratorN((t iter_of_itersR R((s6/var/lib/python-support/python2.5/rdiff_backup/lazy.pytcat20s cCsx|D] }dSqWdS(sTrue if iterator has length 0iN(tNone(R R((s6/var/lib/python-support/python2.5/rdiff_backup/lazy.pytempty5scCs ||jS(((txty((s6/var/lib/python-support/python2.5/rdiff_backup/lazy.pyt:scCsÉx|D]y}y|iƒ}Wn.tj o"|od|fGHndSnX|||ƒp"|od||fGHndSqqWy|iƒ}Wntj o dSnX|od|fGHndS(slTrue if iterator 1 has same elements as iterator 2 Use equality operator, or == if it is unspecified. sEnd when i1 = %ss%s not equal to %sisEnd when i2 = %sN(tnextt StopIterationR(titer1titer2tverbosetoperatorti1ti2((s6/var/lib/python-support/python2.5/rdiff_backup/lazy.pytequal:s&   cCs*d}x|D]}|o|Sq q W|S(s:True if any element in iterator is true. Short circuitingN(R(R R((s6/var/lib/python-support/python2.5/rdiff_backup/lazy.pytOrMs  cCs*d}x|D]}|p|Sq q W|S(s<True if all elements in iterator are true. Short circuitingi((R R((s6/var/lib/python-support/python2.5/rdiff_backup/lazy.pytAndTs  cCsBd}x5y|iƒWntj o |SnX|d}q dS(sReturn length of iteratoriiN(RR(R R((s6/var/lib/python-support/python2.5/rdiff_backup/lazy.pytlen[s c CsFy|iƒ}Wntj o |SnX||ti|||ƒƒS(s0foldr the "fundamental list recursion operator"?(RRRtfoldr(tftdefaultR R((s6/var/lib/python-support/python2.5/rdiff_backup/lazy.pyRcs  cCsCx<y|iƒ}Wntj o |SnX|||ƒ}qdS(s)the fundamental list iteration operator..N(RR(R R!R R((s6/var/lib/python-support/python2.5/rdiff_backup/lazy.pytfoldlis  c sÚˆdjo6ˆ o.ˆ o&tˆƒ}|iƒ|iƒfSnˆp d„‰nˆp d„‰ng‰dgˆ‰ˆ‰dg‰‡‡‡‡‡‡‡‡fd†‰‡fd†}tt|tˆƒƒƒS(sTSplit a single iterater into a number of streams The return val will be a list with length num_of_forks, each of which will be an iterator like iter. final_func is the function that will be called on each element in iter just as it is being removed from the buffer. closing_func is called when all the streams are finished. icSsdS(N(R(R((s6/var/lib/python-support/python2.5/rdiff_backup/lazy.pyR}scSsdS(N(R(((s6/var/lib/python-support/python2.5/rdiff_backup/lazy.pyR~siÿÿÿÿc sˆ|djoyˆidˆiƒƒWnGtj o;ˆˆjo!ˆd oˆƒdˆdR?(R<R@R RA((s6/var/lib/python-support/python2.5/rdiff_backup/lazy.pyR4Âs (R8R9R:R=R3R4(((s6/var/lib/python-support/python2.5/rdiff_backup/lazy.pyR2ªs  ((( R:t __future__RtoststatttypeststaticRt MakeStaticR2(((s6/var/lib/python-support/python2.5/rdiff_backup/lazy.pyss $ Œ