Edit File: coroutines.cpython-36.opt-2.pyc
3 \+ � @ s� d ddgZ ddlZddlZddlZddlZddlZddlZddlZddlm Z ddlm Z ddlm Z dd lm Z dd l mZ ejd Zejj o�eejjd ��ZyejZejZW n ek r� dZdZY nX y ej Z W n ek r� d d� Z Y nX yddl m Z m!Z" W n e#k �r* d Z Z"Y nX dd� Z$e$� Z%[$dd� Z&G dd� d�Z'dd � Ze(� Z)dd� Z ej*e'fZ+e dk �r�e+e f7 Z+edk �r�efe+ Z+dd� Z,dd� Z-dS )� coroutine�iscoroutinefunction� iscoroutine� N� )�compat)� constants)�events)� base_futures)�loggerZ YIELD_FROMZPYTHONASYNCIODEBUGc C s dS )NF� )�funcr r �*/usr/lib64/python3.6/asyncio/coroutines.py�<lambda>/ s r )� Coroutine� Awaitablec C sF G dd� d�} dd� }d}| � }||�}t |� |j|� |j|fkS ) Nc @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S ) z!has_yield_from_bug.<locals>.MyGenc S s d | _ d S )N)� send_args)�selfr r r �__init__; s z*has_yield_from_bug.<locals>.MyGen.__init__c S s | S )Nr )r r r r �__iter__= s z*has_yield_from_bug.<locals>.MyGen.__iter__c S s dS )N�* r )r r r r �__next__? s z*has_yield_from_bug.<locals>.MyGen.__next__c W s || _ d S )N)r )r Zwhatr r r �sendA s z&has_yield_from_bug.<locals>.MyGen.sendN)�__name__� __module__� __qualname__r r r r r r r r �MyGen: s r c s s | E d H d S )Nr )�genr r r �yield_from_genD s z*has_yield_from_bug.<locals>.yield_from_genr � � )r r r )�nextr r )r r �valuer �coror r r �has_yield_from_bug9 s r# c C s t | d �S )N)� CoroWrapper)r r r r � debug_wrapperP s r% c @ s� e Zd Zd%dd�Zdd� Zdd� Zdd � Zer8d d � Znd d � Zd&d d�Z dd� Z e dd� �Z e dd� �Z e dd� �Zejr�dd� Ze dd� �Ze dd � �Ze d d � �Ze d d � �Ze d!d"� �Zd#d$� ZdS )'r$ Nc C s> || _ || _tjtjd��| _t|dd �| _t|dd �| _ d S )Nr r r ) r r r � extract_stack�sys� _getframe�_source_traceback�getattrr r )r r r r r r r [ s zCoroWrapper.__init__c C s@ t | �}| jr0| jd }|d|d |d f 7 }d| jj|f S )Nr z, created at %s:%sr z<%s %s>���)�_format_coroutiner) � __class__r )r � coro_repr�framer r r �__repr__c s zCoroWrapper.__repr__c C s | S )Nr )r r r r r j s zCoroWrapper.__iter__c C s | j jd �S )N)r r )r r r r r m s zCoroWrapper.__next__c G s4 t j� }|j}|jj|j tkr(|d }| jj|�S )Nr ) r' r( �f_back�f_code�co_code�f_lasti� _YIELD_FROMr r )r r! r/ Zcallerr r r r u s zCoroWrapper.sendc C s | j j|�S )N)r r )r r! r r r r } s c C s | j j|||�S )N)r �throw)r �typer! � tracebackr r r r6 � s zCoroWrapper.throwc C s | j j� S )N)r �close)r r r r r9 � s zCoroWrapper.closec C s | j jS )N)r �gi_frame)r r r r r: � s zCoroWrapper.gi_framec C s | j jS )N)r � gi_running)r r r r r; � s zCoroWrapper.gi_runningc C s | j jS )N)r �gi_code)r r r r r< � s zCoroWrapper.gi_codec C s, t | jdd �}|d k r(tdj| j|���| S )N�cr_awaitz;Cannot await on coroutine {!r} while it's awaiting for {!r})r* r � RuntimeError�format)r r= r r r � __await__� s zCoroWrapper.__await__c C s | j jS )N)r � gi_yieldfrom)r r r r rA � s zCoroWrapper.gi_yieldfromc C s | j jS )N)r r= )r r r r r= � s zCoroWrapper.cr_awaitc C s | j jS )N)r � cr_running)r r r r rB � s zCoroWrapper.cr_runningc C s | j jS )N)r �cr_code)r r r r rC � s zCoroWrapper.cr_codec C s | j jS )N)r �cr_frame)r r r r rD � s zCoroWrapper.cr_framec C s� t | dd �}t |dd �}|d kr,t |dd �}|d k r�|jd kr�d| }t | df �}|r�djtj|��}|dtj� d �7 }||j� 7 }tj |� d S ) Nr r: rD r z%r was never yielded fromr) � zB Coroutine object created at (most recent call last, truncated to z last lines): r+ ) r* r4 �joinr8 � format_listr ZDEBUG_STACK_DEPTH�rstripr �error)r r r/ �msg�tbr r r �__del__� s zCoroWrapper.__del__)N)NN)r r r r r0 r r �_YIELD_FROM_BUGr r6 r9 �propertyr: r; r< r ZPY35r@ rA r= rB rC rD rL r r r r r$ X s( r$ c sp t ��r �S tj��r �� ntj���fdd��� tsNtd krD� }qft� �}ntj��� �fdd��}t|_|S )Nc ? sv � | |�}t j|�s(tj|�s(t|t�r4|E d H }n>td k rry |j}W n tk rZ Y nX t|t�rr|� E d H }|S )N) r Zisfuture�inspectZ isgenerator� isinstancer$ � _AwaitableABCr@ �AttributeError)�args�kw�resZ await_meth)r r r r" � s zcoroutine.<locals>.coroc s@ t � | |��d�}|jr |jd= t�dd �|_t�dd �|_|S )N)r r r r r+ )r$ r) r* r r )rS �kwds�w)r" r r r �wrapper� s zcoroutine.<locals>.wrapper)� _inspect_iscoroutinefunctionrO �isgeneratorfunction� functools�wraps�_DEBUG�_types_coroutine� _is_coroutine)r rX r )r" r r r � s c C s t | dd �tkpt| �S )Nr_ )r* r_ rY )r r r r r � s c C s t | t�S )N)rP �_COROUTINE_TYPES)�objr r r r s c C s t | d� r�t | d� r�t| dt| dt| �j��}dj|�}d}y | j}W n4 tk r~ y | j}W n tk rx Y nX Y nX |r�dj|�S |S d }t| t �r�| j }| j }|d k r�dj|�}n| }|d kr�t j |f i �}d }t | d�r�| jr�| j}nt | d��r| j�r| j}d }t | d��r0| j�r0| j}nt | d ��rJ| j�rJ| j}d }|�rb|j�rb|j}d }|}t| t ��r�tj| j � �r�| j d k �r�t j| j �} | d k �r�| \}}|d k�r�d |||f }nd |||f }n:|d k �r�|j}d|||f }n|�r|j}d |||f }|S )NrC r< r r z{}()Fz {} runningrD r: z<empty co_filename>r z%s done, defined at %s:%sz %s running, defined at %s:%sz%s running at %s:%s)�hasattrr* r7 r r? rB rR r; rP r$ r r r Z_format_callbackrC r< rD r: � co_filenamerO rZ Z_get_function_source�f_lineno�co_firstlineno) r" Z coro_nameZrunningr Z coro_codeZ coro_frame�filename�linenor. �sourcer r r r, sx r, ).�__all__r[ rO Zopcode�osr' r8 �typesrE r r r r �logr Zopmapr5 �flags�ignore_environment�bool�environ�getr] r r^ � CoroutineTypeZ_types_CoroutineTyperR r rY �collections.abcr Z _CoroutineABCr rQ � ImportErrorr# rM r% r$ �objectr_ � GeneratorTyper` r r, r r r r �<module> sZ j: