ó ‰]c@sÀdZddlZddlmZyddlZWnek rKdZnXejdeddƒd„Z d„Z ed e fd „ƒYƒZ d e fd „ƒYZ d e fd„ƒYZdS(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: https://github.com/python-greenlet/greenlet :copyright: 2007 Pallets :license: BSD-3-Clause iÿÿÿÿNi(timplements_iterators^'werkzeug.contrib.iterio' is deprecated as of version 0.15 and will be removed in version 1.0.t stacklevelcCsLt|ƒ}t||ƒ}t|tƒr;|dj|ƒS|dj|ƒS(s2concatenate any string type in an intelligent way.tu(titertnextt isinstancetbytestjoin(titerabletsentineltiteratort first_item((s6lib/python2.7/site-packages/werkzeug/contrib/iterio.pyt _mixed_join;s  cCst|tƒrdSdS(Ns u (RR(treference_string((s6lib/python2.7/site-packages/werkzeug/contrib/iterio.pyt_newlineDstIterIOcBs•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 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(tclstobjR R ((s6lib/python2.7/site-packages/werkzeug/contrib/iterio.pyt__new__fs  cCs|S(N((tself((s6lib/python2.7/site-packages/werkzeug/contrib/iterio.pyt__iter__mscCs|jrtdƒ‚n|jS(NsI/O operation on closed file(tclosedt ValueErrortpos(R((s6lib/python2.7/site-packages/werkzeug/contrib/iterio.pyttellps cCs|jrtdƒ‚ntS(NsI/O operation on closed file(RRtFalse(R((s6lib/python2.7/site-packages/werkzeug/contrib/iterio.pytisattyus icCs+|jrtdƒ‚ntddƒ‚dS(NsI/O operation on closed filei sBad file descriptor(RRtIOError(RRtmode((s6lib/python2.7/site-packages/werkzeug/contrib/iterio.pytseekzs cCs+|jrtdƒ‚ntddƒ‚dS(NsI/O operation on closed filei sBad file descriptor(RRR(Rtsize((s6lib/python2.7/site-packages/werkzeug/contrib/iterio.pyttruncates cCs+|jrtdƒ‚ntddƒ‚dS(NsI/O operation on closed filei sBad file descriptor(RRR(Rts((s6lib/python2.7/site-packages/werkzeug/contrib/iterio.pytwrite„s cCs+|jrtdƒ‚ntddƒ‚dS(NsI/O operation on closed filei sBad file descriptor(RRR(Rtlist((s6lib/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((s6lib/python2.7/site-packages/werkzeug/contrib/iterio.pytreadŽs cCs+|jrtdƒ‚ntddƒ‚dS(NsI/O operation on closed filei sBad file descriptor(RRR(Rtsizehint((s6lib/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((s6lib/python2.7/site-packages/werkzeug/contrib/iterio.pytreadline˜s cCs+|jrtdƒ‚ntddƒ‚dS(NsI/O operation on closed filei sBad file descriptor(RRR(R((s6lib/python2.7/site-packages/werkzeug/contrib/iterio.pytflushs cCs7|jrtƒ‚n|jƒ}|s3tƒ‚n|S(N(Rt StopIterationR,(Rtline((s6lib/python2.7/site-packages/werkzeug/contrib/iterio.pyt__next__¢s     N(t__name__t __module__t__doc__RRRRR tNoneR"R$R&R(R*R,R-R0(((s6lib/python2.7/site-packages/werkzeug/contrib/iterio.pyRJs            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‡WdS(NsIterI requires greenlet supporticsˆˆƒˆjƒdS(N(tclose((tfunctstream(s6lib/python2.7/site-packages/werkzeug/contrib/iterio.pytrun¸s ( tgreenletR4t RuntimeErrortobjectRt getcurrentt_parentt_bufferRRR Rtswitch(RR6R R8tgtrv((R6R7s6lib/python2.7/site-packages/werkzeug/contrib/iterio.pyR®s      cCs#|jst|_|jƒndS(N(RtTruet _flush_impl(R((s6lib/python2.7/site-packages/werkzeug/contrib/iterio.pyR5Ãs  cCsJ|jrtdƒ‚n|rF|jt|ƒ7_|jj|ƒndS(NsI/O operation on closed file(RRRtlenR>tappend(RR#((s6lib/python2.7/site-packages/werkzeug/contrib/iterio.pyR$Ès  cCs"x|D]}|j|ƒqWdS(N(R$(RR%titem((s6lib/python2.7/site-packages/werkzeug/contrib/iterio.pyR&Ïs cCs&|jrtdƒ‚n|jƒdS(NsI/O operation on closed file(RRRC(R((s6lib/python2.7/site-packages/werkzeug/contrib/iterio.pyR-Ós cCsUt|j|jƒ}g|_| r>|jr>|jjƒn|jj|fƒdS(N(R R>R RR=R?(Rtdata((s6lib/python2.7/site-packages/werkzeug/contrib/iterio.pyRCØs  ( R1R2R3RR5R$R&R-RC(((s6lib/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_genR4t_bufR RRR(RtgenR R((s6lib/python2.7/site-packages/werkzeug/contrib/iterio.pyRäs     cCs|S(N((R((s6lib/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(RI(Rtstring((s6lib/python2.7/site-packages/werkzeug/contrib/iterio.pyt _buf_appendðs  cCs;|js7t|_t|jdƒr7|jjƒq7ndS(NR5(RRBthasattrRHR5(R((s6lib/python2.7/site-packages/werkzeug/contrib/iterio.pyR5øs  icCs/|jrtdƒ‚n|dkr4||j7}nQ|dkrj|jƒt|j|j|ƒ|_dS|dkr…tdƒ‚ng}yXt|jpdƒ}x<||krát|j ƒ}|t|ƒ7}|j |ƒq¦WWnt k rönX|r|j t ||jƒƒntd|ƒ|_dS(NsI/O operation on closed fileiiisInvalid argumentR(RRRR(tminRRDRIRRHRER.RLR R tmax(RRRtbuft tmp_end_posRF((s6lib/python2.7/site-packages/werkzeug/contrib/iterio.pyR þs,      iÿÿÿÿcCsŒ|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(RRRLR RHR RIRRDR4RRER.RORN(RR'tresulttnew_posRPRQRF((s6lib/python2.7/site-packages/werkzeug/contrib/iterio.pyR(s2   $% cCsÈ|jrtdƒ‚nd}|jrK|jjt|jƒ|jƒ}ng}yœ|jdkro|j}nt|jƒ}xk|dkrët|j ƒ}|jt|ƒƒ}|j |ƒ|dkrØ||}Pn|t|ƒ7}qWWnt k rnX|r#|j t ||jƒƒn|jdkr9|jS|dkrWt|jƒ}n |d}|dk r|j||kr|j|}nz|j|j|!SWdt|t|jƒƒ|_XdS(NsI/O operation on closed fileiÿÿÿÿii(RRRItfindRRR4RDRRHRER.RLR R RN(RR+tnl_posRPRRFt local_posRS((s6lib/python2.7/site-packages/werkzeug/contrib/iterio.pyR,4s@  $       cCsrd}g}|jƒ}xS|rm|j|ƒ|t|ƒ7}d|koU|knr^Pn|jƒ}qW|S(Ni(R,RERD(RR)ttotaltlinesR/((s6lib/python2.7/site-packages/werkzeug/contrib/iterio.pyR*\s   N( R1R2R3RRRLR5R R(R4R,R*(((s6lib/python2.7/site-packages/werkzeug/contrib/iterio.pyRás      ((R3twarningst_compatRR9t ImportErrorR4twarntDeprecationWarningR RR;RRR(((s6lib/python2.7/site-packages/werkzeug/contrib/iterio.pyt)s     `6