ó `¾Tc@sždZyddlZWnek r/dZnXddlmZd„Zd„Zedefd„ƒYƒZ de fd „ƒYZ d e fd „ƒYZ dS( s werkzeug.contrib.iterio ~~~~~~~~~~~~~~~~~~~~~~~ This module implements a :class:`IterIO` that converts an iterator into a stream object and the other way round. Converting streams into iterators requires the `greenlet`_ module. To convert an iterator into a stream all you have to do is to pass it directly to the :class:`IterIO` constructor. In this example we pass it a newly created generator:: def foo(): yield "something\n" yield "otherthings" stream = IterIO(foo()) print stream.read() # read the whole iterator The other way round works a bit different because we have to ensure that the code execution doesn't take place yet. An :class:`IterIO` call with a callable as first argument does two things. The function itself is passed an :class:`IterIO` stream it can feed. The object returned by the :class:`IterIO` constructor on the other hand is not an stream object but an iterator:: def foo(stream): stream.write("some") stream.write("thing") stream.flush() stream.write("otherthing") iterator = IterIO(foo) print iterator.next() # prints something print iterator.next() # prints otherthing iterator.next() # raises StopIteration .. _greenlet: http://codespeak.net/py/dist/greenlet.html :copyright: (c) 2014 by the Werkzeug Team, see AUTHORS for more details. :license: BSD, see LICENSE for more details. iÿÿÿÿN(timplements_iteratorcCsLt|ƒ}t||ƒ}t|tƒr;|dj|ƒS|dj|ƒS(s2concatenate any string type in an intelligent way.tu(titertnextt isinstancetbytestjoin(titerabletsentineltiteratort first_item((s]/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyt _mixed_join2s  cCst|tƒrdSdS(Ns u (RR(treference_string((s]/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyt_newline;stIterIOcBs•eZdZdd„Zd„Zd„Zd„Zdd„Zdd„Z d „Z d „Z d d „Z dd „Z dd„Zd„Zd„ZRS(sÄInstances of this object implement an interface compatible with the standard Python :class:`file` object. Streams are either read-only or write-only depending on how the object is created. If the first argument is an iterable a file like object is returned that returns the contents of the iterable. In case the iterable is empty read operations will return the sentinel value. If the first argument is a callable then the stream object will be created and passed to that function. The caller itself however will not receive a stream but an iterable. The function will be be executed step by step as something iterates over the returned iterable. Each call to :meth:`flush` will create an item for the iterable. If :meth:`flush` is called without any writes in-between the sentinel value will be yielded. Note for Python 3: due to the incompatible interface of bytes and streams you should set the sentinel value explicitly to an empty bytestring (``b''``) if you are expecting to deal with bytes as otherwise the end of the stream is marked with the wrong sentinel value. .. versionadded:: 0.9 `sentinel` parameter was added. RcCs;yt|ƒ}Wntk r-t||ƒSXt||ƒS(N(Rt TypeErrortIterItIterO(tclstobjRR ((s]/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyt__new__]s  cCs|S(N((tself((s]/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyt__iter__dscCs|jrtdƒ‚n|jS(NsI/O operation on closed file(tclosedt ValueErrortpos(R((s]/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyttellgs cCs|jrtdƒ‚ntS(NsI/O operation on closed file(RRtFalse(R((s]/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/werkzeug/contrib/iterio.pytisattyls icCs+|jrtdƒ‚ntddƒ‚dS(NsI/O operation on closed filei sBad file descriptor(RRtIOError(RRtmode((s]/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/werkzeug/contrib/iterio.pytseekqs cCs+|jrtdƒ‚ntddƒ‚dS(NsI/O operation on closed filei sBad file descriptor(RRR(Rtsize((s]/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyttruncatevs cCs+|jrtdƒ‚ntddƒ‚dS(NsI/O operation on closed filei sBad file descriptor(RRR(Rts((s]/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/werkzeug/contrib/iterio.pytwrite{s cCs+|jrtdƒ‚ntddƒ‚dS(NsI/O operation on closed filei sBad file descriptor(RRR(Rtlist((s]/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyt writelines€s iÿÿÿÿcCs+|jrtdƒ‚ntddƒ‚dS(NsI/O operation on closed filei sBad file descriptor(RRR(Rtn((s]/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/werkzeug/contrib/iterio.pytread…s cCs+|jrtdƒ‚ntddƒ‚dS(NsI/O operation on closed filei sBad file descriptor(RRR(Rtsizehint((s]/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyt readlinesŠs cCs+|jrtdƒ‚ntddƒ‚dS(NsI/O operation on closed filei sBad file descriptor(RRR(Rtlength((s]/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/werkzeug/contrib/iterio.pytreadlines cCs+|jrtdƒ‚ntddƒ‚dS(NsI/O operation on closed filei sBad file descriptor(RRR(R((s]/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/werkzeug/contrib/iterio.pytflush”s cCs7|jrtƒ‚n|jƒ}|s3tƒ‚n|S(N(Rt StopIterationR+(Rtline((s]/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyt__next__™s     N(t__name__t __module__t__doc__RRRRRtNoneR!R#R%R'R)R+R,R/(((s]/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyRAs            RcBsGeZdZdd„Zd„Zd„Zd„Zd„Zd„ZRS(s#Convert an stream into an iterator.Rc#s­tdkrtdƒ‚ntj|ƒ‰tjƒˆ_gˆ_tˆ_ |ˆ_ dˆ_ ‡‡fd†}tj|ˆjƒ}x"|j ƒ}|sdS|dVq‡dS(NsIterI requires greenlet supporticsˆˆƒˆjƒdS(N(tclose((tstreamtfunc(s]/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/werkzeug/contrib/iterio.pytrun¯s ( tgreenletR3t RuntimeErrortobjectRt getcurrentt_parentt_bufferRRRRtswitch(RR6RR7tgtrv((R5R6s]/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyR¥s      cCs#|jst|_|jƒndS(N(RtTruet _flush_impl(R((s]/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyR4ºs  cCsJ|jrtdƒ‚n|rF|jt|ƒ7_|jj|ƒndS(NsI/O operation on closed file(RRRtlenR=tappend(RR"((s]/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyR#¿s  cCs"x|D]}|j|ƒqWdS(N(R#(RR$titem((s]/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyR%Æs cCs&|jrtdƒ‚n|jƒdS(NsI/O operation on closed file(RRRB(R((s]/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyR,Ês cCsUt|j|jƒ}g|_| r>|jr>|jjƒn|jj|fƒdS(N(R R=RRR<R>(Rtdata((s]/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyRBÏs  ( R0R1R2RR4R#R%R,RB(((s]/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyR¢s     RcBseeZdZdd„Zd„Zd„Zd„Zdd„Zdd „Zd d „Z dd „Z RS( sCIter output. Wrap an iterator and give it a stream like interface.RcCs@tj|ƒ}||_d|_||_t|_d|_|S(Ni( R:Rt_genR3t_bufRRRR(RtgenRR((s]/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyRÛs     cCs|S(N((R((s]/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyRäscCs(|js||_n|j|7_dS(s[Replace string directly without appending to an empty string, avoiding type issues.N(RH(Rtstring((s]/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyt _buf_appendçs  cCs;|js7t|_t|jdƒr7|jjƒq7ndS(NR4(RRAthasattrRGR4(R((s]/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyR4ïs  icCs)|jrtdƒ‚n|dkr4||j7}nQ|dkrj|jƒt|j|j|ƒ|_dS|dkr…tdƒ‚ng}yRt|jƒ}x<||krÛ|jj ƒ}|t|ƒ7}|j |ƒq WWnt k rðnX|r|j t ||jƒƒntd|ƒ|_dS(NsI/O operation on closed fileiiisInvalid argument(RRRR'tminRRCRHRGRRDR-RKR Rtmax(RRRtbuft tmp_end_posRE((s]/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyRõs,      iÿÿÿÿc CsŒ|jrtdƒ‚n|dkri|jt|j|jƒƒ|j|j}|jt|ƒ7_|S|j|}g}y}|jdkr”dn t|jƒ}xR||ksÈ|jdkr÷| r÷t |jƒ}|t|ƒ7}|j |ƒq¦WWnt k r nX|r/|jt||jƒƒn|jdkrE|jSt d|ƒ}z|j|j|!SWdt|t|jƒƒ|_XdS(NsI/O operation on closed filei(RRRKR RGRRHRRCR3RRDR-RNRM(RR&tresulttnew_posRORPRE((s]/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyR' s2   $% cCs§|jrtdƒ‚nd}|jrK|jjt|jƒ|jƒ}ng}y{|j}xk|dkrÊt|jƒ}|jt|ƒƒ}|j|ƒ|dkr·||}Pn|t |ƒ7}q`WWnt k rßnX|r|j t ||j ƒƒn|jdkr|j S|dkr6t |jƒ}n |d}|dk ro|j||kro|j|}nz|j|j|!SWdt|t |jƒƒ|_XdS(NsI/O operation on closed fileiÿÿÿÿii(RRRHtfindR RRRGRDRCR-RKR RR3RM(RR*tnl_posRORREt local_posRR((s]/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyR++s<  $       cCsrd}g}|jƒ}xS|rm|j|ƒ|t|ƒ7}d|koU|knr^Pn|jƒ}qW|S(Ni(R+RDRC(RR(ttotaltlinesR.((s]/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyR)Ps   N( R0R1R2RRRKR4RR'R3R+R)(((s]/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyRØs      %( R2R8t ImportErrorR3twerkzeug._compatRR R R:RRR(((s]/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyt)s   `6