Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/vine/__pycache__/promises.cpython-39.pyc
Ðазад
a ^�h � @ sf d Z ddlZddlZddlmZ ddlmZmZ ddlm Z ddl m Z dgZ e j G d d� d��ZdS ) zPromise implementation.� N)�deque)� WeakMethod�ref� )�Thenable)�reraise�promisec @ s~ e Zd ZdZeed�sdZddd�Zedd � �Z d d � Z d d � Z dd� Z dd� Z d dd�Zd dd�Zd dd�Zedd� �ZdS ) r a~ Promise of future evaluation. This is a special implementation of promises in that it can be used both for "promise of a value" and lazy evaluation. The biggest upside for this is that everything in a promise can also be a promise, e.g. filters, callbacks and errbacks can all be promises. Usage examples: .. code-block:: python >>> p = promise() >>> p.then(promise(print, ('OK',))) # noqa >>> p.on_error = promise(print, ('ERROR',)) # noqa >>> p(20) OK, 20 >>> p.then(promise(print, ('hello',))) # noqa hello, 20 >>> p.throw(KeyError('foo')) ERROR, KeyError('foo') >>> p2 = promise() >>> p2.then(print) # noqa >>> p2.cancel() >>> p(30) Example: .. code-block:: python from vine import promise, wrap class Protocol: def __init__(self): self.buffer = [] def receive_message(self): return self.read_header().then( self.read_body).then( wrap(self.prepare_body)) def read(self, size, callback=None): callback = callback or promise() tell_eventloop_to_read(size, callback) return callback def read_header(self, callback=None): return self.read(4, callback) def read_body(self, header, callback=None): body_size, = unpack('>L', header) return self.read(body_size, callback) def prepare_body(self, value): self.buffer.append(value) �pypy_version_info)�fun�args�kwargs�ready�failed�value� ignore_result�reason� _svpending� _lvpending�on_error� cancelled�weak� __weakref__�__dict__NFc C s� || _ || _| j||d�| _|p"d| _|p,i | _d| _d| _d | _d | _ d | _ d | _ || _ d| _ |d urr| �|� | jr�| jr�t|�s�J �d S )N�r r � F)r r �_get_fun_or_weakrefr r r r r r r r r r r �then�callable)�selfr r r �callbackr r r r r �}/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/vine/promises.py�__init__T s" zpromise.__init__c C s& |s| S t �| �rt| �S t| �S dS )zbReturn the callable or a weak reference. Handles both bound and unbound methods. N)�inspect�ismethodr r r r r r r o s zpromise._get_fun_or_weakrefc C s. | j r dnd�t| �j� dt| �d��| j �S )Nz<{0} --> {1!r}>z<{0}>z@0x�x)r �format�type�__name__�id�r r r r �__repr__} s �zpromise.__repr__c C s~ d| _ z^| jd ur | j�� | jd ur:| jD ] }|�� q,t| jt�rP| j�� W d | _ | _| _nd | _ | _| _0 d S )NT)r r �cancelr � isinstancer r )r �pendingr r r r+ � s zpromise.cancelc O s> d }| j rd S |r | j| n| j}|r8t| jfi |��n| j}| �| j�}|d ur�zD| jrr||i |�� d}i }n"||i |��}|fi f | _\}}W q� ty� | � � Y S 0 n||f | _\}}d| _ | j } | d u�r z| |i |�� W d | _ nd | _ 0 n:| j } z*| �r(| � � } | |i |�� �qW d | _ nd | _ 0 |S )Nr T)r r �dictr � _fun_is_aliver r r � Exception�throwr r r �popleft) r r r �retvalZ final_argsZ final_kwargsr �caZck� svpending� lvpending�pr r r �__call__� s< zpromise.__call__c C s | j r |� S | jS �N)r r )r r r r r r/ � s zpromise._fun_is_alivec C s� t |t�st||d�}| jr(|�� |S | jr<|�| j� n | jrZ| j \}}||i |�� | j d u r�| j }|d ur�d t |g� | _ | _ n || _ |S | j � |� |S )N)r )r, r r r r+ r r1 r r r r r r �append)r r r r r r5 r r r r � s$ z promise.thenc C sP | j sL|d ur|n t�� d }d| | _| _| jrL| j| j|f i | j�� d S )Nr T)r �sys�exc_infor r r r r )r �excr r r �throw1� s zpromise.throw1Tc C s | j �st�� d }|d ur |n|}z�| �|� | j}|d ur^z|�|� W d | _q�d | _0 n.| j}z |rz|�� �|� qfW d | _nd | _0 W | jd u r�|r�|d u r�|d u s�||u r�� tt |�||� n>| jd u �r|�r|d u r�|d u s�||u r� tt |�||� 0 d S )Nr ) r r; r< r> r r r2 r r r& )r r= �tb� propagateZ current_excr5 r6 r r r r1 � s. �z promise.throwc C s | j r | j S | jgS r9 )r r r) r r r � listeners� s zpromise.listeners)NNNNNFF)N)N)NNT)r' � __module__� __qualname__�__doc__�hasattrr; � __slots__r! � staticmethodr r* r+ r8 r/ r r> r1 �propertyrA r r r r r s$ < � & )rD r" r; � collectionsr �weakrefr r �abstractr �utilsr �__all__�registerr r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка