File manager - Edit - /opt/imh-python/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyc
Back
� �ْSc @ s� d Z y d d l Z Wn e k r/ d Z n Xd d l m Z d � Z d � Z e d e f d � � Y� Z d e f d � � YZ d e f d � � YZ d S( 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( t implements_iteratorc C sL t | � } t | | � } t | t � r; | d j | � S| d j | � S( s2 concatenate any string type in an intelligent way.t u ( t itert nextt isinstancet bytest join( t iterablet sentinelt iteratort first_item( ( sF /opt/imh-python/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyt _mixed_join2 s c C s t | t � r d Sd S( Ns u ( R R ( t reference_string( ( sF /opt/imh-python/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyt _newline; s t IterIOc B s� e Z d Z d d � Z d � Z d � Z d � Z d d � Z d d � Z d � Z d � Z d d � Z d d � Z d d � Z d � Z d � Z RS( 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. R c C s; y t | � } Wn t k r- t | | � SXt | | � S( N( R t TypeErrort IterIt IterO( t clst objR R ( ( sF /opt/imh-python/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyt __new__] s c C s | S( N( ( t self( ( sF /opt/imh-python/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyt __iter__d s c C s | j r t d � � n | j S( Ns I/O operation on closed file( t closedt ValueErrort pos( R ( ( sF /opt/imh-python/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyt tellg s c C s | j r t d � � n t S( Ns I/O operation on closed file( R R t False( R ( ( sF /opt/imh-python/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyt isattyl s i c C s+ | j r t d � � n t d d � � d S( Ns I/O operation on closed filei s Bad file descriptor( R R t IOError( R R t mode( ( sF /opt/imh-python/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyt seekq s c C s+ | j r t d � � n t d d � � d S( Ns I/O operation on closed filei s Bad file descriptor( R R R ( R t size( ( sF /opt/imh-python/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyt truncatev s c C s+ | j r t d � � n t d d � � d S( Ns I/O operation on closed filei s Bad file descriptor( R R R ( R t s( ( sF /opt/imh-python/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyt write{ s c C s+ | j r t d � � n t d d � � d S( Ns I/O operation on closed filei s Bad file descriptor( R R R ( R t list( ( sF /opt/imh-python/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyt writelines� s i����c C s+ | j r t d � � n t d d � � d S( Ns I/O operation on closed filei s Bad file descriptor( R R R ( R t n( ( sF /opt/imh-python/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyt read� s c C s+ | j r t d � � n t d d � � d S( Ns I/O operation on closed filei s Bad file descriptor( R R R ( R t sizehint( ( sF /opt/imh-python/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyt readlines� s c C s+ | j r t d � � n t d d � � d S( Ns I/O operation on closed filei s Bad file descriptor( R R R ( R t length( ( sF /opt/imh-python/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyt readline� s c C s+ | j r t d � � n t d d � � d S( Ns I/O operation on closed filei s Bad file descriptor( R R R ( R ( ( sF /opt/imh-python/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyt flush� s c C s7 | j r t � � n | j � } | s3 t � � n | S( N( R t StopIterationR+ ( R t line( ( sF /opt/imh-python/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyt __next__� s N( t __name__t __module__t __doc__R R R R R t NoneR! R# R% R' R) R+ R, R/ ( ( ( sF /opt/imh-python/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyR A s R c B sG e Z d Z d d � Z d � Z d � Z d � Z d � Z d � Z RS( s# Convert an stream into an iterator.R c # s� t d k r t d � � n t j | � � t j � � _ g � _ t � _ | � _ d � _ � � f d � } t j | � j � } x# | j � } | s� d S| d Vq� Wd S( Ns IterI requires greenlet supporti c s � � � � j � d S( N( t close( ( t funct stream( sF /opt/imh-python/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyt run� s ( t greenletR3 t RuntimeErrort objectR t getcurrentt _parentt _bufferR R R R t switch( R R5 R R7 t gt rv( ( R5 R6 sF /opt/imh-python/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyR � s c C s# | j s t | _ | j � n d S( N( R t Truet _flush_impl( R ( ( sF /opt/imh-python/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyR4 � s c C sJ | j r t d � � n | rF | j t | � 7_ | j j | � n d S( Ns I/O operation on closed file( R R R t lenR= t append( R R" ( ( sF /opt/imh-python/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyR# � s c C s" x | D] } | j | � q Wd S( N( R# ( R R$ t item( ( sF /opt/imh-python/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyR% � s c C s& | j r t d � � n | j � d S( Ns I/O operation on closed file( R R RB ( R ( ( sF /opt/imh-python/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyR, � s c C sU t | j | j � } g | _ | r> | j r> | j j � n | j j | f � d S( N( R R= R R R< R> ( R t data( ( sF /opt/imh-python/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyRB � s ( R0 R1 R2 R R4 R# R% R, RB ( ( ( sF /opt/imh-python/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyR � s R c B se e Z d Z d d � Z d � Z d � Z d � Z d d � Z d d � Z d d � Z d d � Z RS( sC Iter output. Wrap an iterator and give it a stream like interface.R c C s@ t j | � } | | _ d | _ | | _ t | _ d | _ | S( Ni ( R: R t _genR3 t _bufR R R R ( R t genR R ( ( sF /opt/imh-python/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyR � s c C s | S( N( ( R ( ( sF /opt/imh-python/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyR � s c C s( | j s | | _ n | j | 7_ d S( s[ Replace string directly without appending to an empty string, avoiding type issues.N( RH ( R t string( ( sF /opt/imh-python/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyt _buf_append� s c C s; | j s7 t | _ t | j d � r7 | j j � q7 n d S( NR4 ( R RA t hasattrRG R4 ( R ( ( sF /opt/imh-python/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyR4 � s i c C s) | j r t d � � n | d k r4 | | j 7} nQ | d k rj | j � t | j | j | � | _ d S| d k r� t d � � n g } yR t | j � } x< | | k r� | j j � } | t | � 7} | j | � q� WWn t k r� n X| r| j t | | j � � n t d | � | _ d S( Ns I/O operation on closed filei i i s Invalid argument( R R R R' t minR RC RH RG R RD R- RK R R t max( R R R t buft tmp_end_posRE ( ( sF /opt/imh-python/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyR � s, i����c C s� | j r t d � � n | d k ri | j t | j | j � � | j | j } | j t | � 7_ | S| j | } g } y} | j d k r� d n t | j � } xR | | k s� | j d k r� | r� t | j � } | t | � 7} | j | � q� WWn t k r n X| r/| j t | | j � � n | j d k rE| j St d | � } z | j | j | !SWd t | t | j � � | _ Xd S( Ns I/O operation on closed filei ( R R RK R RG R RH R RC R3 R RD R- RN RM ( R R& t resultt new_posRO RP RE ( ( sF /opt/imh-python/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyR' s2 $% c C s� | j r t d � � n d } | j rK | j j t | j � | j � } n g } y{ | j } xk | d k r� t | j � } | j t | � � } | j | � | d k r� | | } Pn | t | � 7} q` WWn t k r� n X| r| j t | | j � � n | j d k r| j S| d k r6t | j � } n | d } | d k ro| j | | k ro| j | } n z | j | j | !SWd t | t | j � � | _ Xd S( Ns I/O operation on closed filei����i i ( R R RH t findR R R RG RD RC R- RK R R R3 RM ( R R* t nl_posRO R RE t local_posRR ( ( sF /opt/imh-python/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyR+ + s< $ c C sr d } g } | j � } xS | rm | j | � | t | � 7} d | k oU | k n r^ Pn | j � } q W| S( Ni ( R+ RD RC ( R R( t totalt linesR. ( ( sF /opt/imh-python/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyR) P s N( R0 R1 R2 R R RK R4 R R' R3 R+ R) ( ( ( sF /opt/imh-python/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyR � s %( R2 R8 t ImportErrorR3 t werkzeug._compatR R R R: R R R ( ( ( sF /opt/imh-python/lib/python2.7/site-packages/werkzeug/contrib/iterio.pyt <module>) s `6
| ver. 1.4 |
Github
|
.
| PHP 8.3.31 | Generation time: 0 |
proxy
|
phpinfo
|
Settings