File: //usr/lib/python3.5/asyncio/__pycache__/coroutines.cpython-35.pyc
Fa) @ s( d d d g Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l m Z d d l m
Z
d d l m Z d d l m
Z
e j d
Z e j j o e e j j d Z y e j Z e j Z Wn e k
r d Z d Z Yn Xy
e j Z Wn e k
r9d d
Z Yn Xy d d l m Z m Z! Wn e" k
rrd Z Z! Yn Xd d Z# e# Z$ [# d d Z% Gd d d Z& d d Z e' Z( d d Z e j) e& f Z* e d k re* e f 7Z* e d k r e f e* Z* d d Z+ d d Z, d S) coroutineiscoroutinefunction iscoroutine N )compat)events)futures)loggerZ
YIELD_FROMZPYTHONASYNCIODEBUGc C s d S)NF )funcr
r
(/usr/lib/python3.5/asyncio/coroutines.py<lambda>. s r
) Coroutine Awaitablec C sa Gd d d } d d } d } | } | | } t | | j | | j | f k S) Nc @ s@ e Z d Z d d Z d d Z d d Z d d Z d 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 d S)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 send@ s z&has_yield_from_bug.<locals>.MyGen.sendN)__name__
__module__ __qualname__r r r r r
r
r
r MyGen9 s r c s s
| Ed Hd S)Nr
)genr
r
r yield_from_genC s z*has_yield_from_bug.<locals>.yield_from_genr )r r r )nextr r )r r valuer coror
r
r has_yield_from_bug8 s
r" c C s
t | d S)N) CoroWrapper)r r
r
r
debug_wrapperO s r$ c @ s3 e Z d Z d d d Z d d Z d d Z d d Z e rT d
d Z n d d Z d d d
d Z d d Z
e d d Z e d d Z
e d d Z e j r#d d Z e d d Z e d d Z e d d Z e d d Z e d! d" Z d# d$ Z d S)%r# Nc C s t j | s* t j | s* t | | | _ | | _ t j t j d | _
t | d d | _ t | d d | _
d S)Nr r r )inspect isgeneratorr AssertionErrorr r traceback
extract_stacksys _getframe_source_tracebackgetattrr r )r r r r
r
r r Z s * zCoroWrapper.__init__c C sR t | } | j r> | j d } | d | d | d f 7} d | j j | f S)Nr z, created at %s:%sr z<%s %s>)_format_coroutiner, __class__r )r coro_reprframer
r
r __repr__b s
zCoroWrapper.__repr__c C s | S)Nr
)r r
r
r r i s zCoroWrapper.__iter__c C s | j j d S)N)r r )r r
r
r r l s zCoroWrapper.__next__c G s] t j } | j } | j d k s* t | j j | j t k rM | d } | j j | S)Nr )
r* r+ f_backf_lastir' f_codeco_code _YIELD_FROMr r )r r r2 Zcallerr
r
r r t 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 r( r
r
r r9 s zCoroWrapper.throwc C s
| j j S)N)r close)r r
r
r r; s zCoroWrapper.closec C s
| j j S)N)r gi_frame)r r
r
r r< s zCoroWrapper.gi_framec C s
| j j S)N)r
gi_running)r r
r
r r= s zCoroWrapper.gi_runningc C s
| j j S)N)r gi_code)r r
r
r r> s zCoroWrapper.gi_codec C s@ t | j d d } | d k r< t d j | j | | S)Ncr_awaitz;Cannot await on coroutine {!r} while it's awaiting for {!r})r- r RuntimeErrorformat)r r? r
r
r __await__ s zCoroWrapper.__await__c C s
| j j S)N)r gi_yieldfrom)r r
r
r rC s zCoroWrapper.gi_yieldfromc C s
| j j S)N)r r? )r r
r
r r? s zCoroWrapper.cr_awaitc C s
| j j S)N)r
cr_running)r r
r
r rD s zCoroWrapper.cr_runningc C s
| j j S)N)r cr_code)r r
r
r rE s zCoroWrapper.cr_codec C s
| j j S)N)r cr_frame)r r
r
r rF s zCoroWrapper.cr_framec C s t | d d } t | d d } | d k rB t | d d } | d k r | j d k r d | } t | d f } | r d j t j | } | d 7} | | j 7} t j | d S)
Nr r< rF r z%r was never yielded fromr, z6
Coroutine object created at (most recent call last):
r. )r- r5 joinr( format_listrstripr error)r r r2 msgtbr
r
r __del__ s
zCoroWrapper.__del__)r r r r r3 r r _YIELD_FROM_BUGr r9 r; propertyr< r= r> r ZPY35rB rC r? rD rE rF rN r
r
r
r r# W s( r# c s t r St j r( n! t j f d d t ss t d k rd } q t } n$ t j f d d } t | _ | S)zDecorator to mark coroutines.
If the coroutine is not yielded from before it is destroyed,
an error message is logged.
c ? s | | } t j | s< t j | s< t | t rJ | Ed H} nK t d k r y
| j } Wn t k
rw Yn Xt | t r | Ed H} | S)N) r Zisfuturer% r&
isinstancer#
_AwaitableABCrB AttributeError)argskwZresZ
await_meth)r r
r r! s
zcoroutine.<locals>.coroNc s\ t | | d } | j r. | j d =t d d | _ t d d | _ | S)Nr r r r r. )r# r, r- r r )rT kwdsw)r! r r
r wrapper s
zcoroutine.<locals>.wrapper) _inspect_iscoroutinefunctionr% isgeneratorfunction functoolswraps_DEBUG_types_coroutine
_is_coroutine)r rX r
)r! r r r s ! $
c C s" t | d d t k p! t | S)z6Return True if func is a decorated coroutine function.r_ N)r- r_ rY )r r
r
r r s c C s
t | t S)z)Return True if obj is a coroutine object.)rQ _COROUTINE_TYPES)objr
r
r r s c
" C sx t | s t t | d r t | d r t | d t | d t | j } d j | } d } y
| j } Wn4 t k
r y
| j } Wn t k
r Yn XYn X| r d j | S| Sd } t
| t r| j } | j
} | d k rd j | } n | } | d k r5t j | f i } y
| j } Wn t k
r_| j } Yn Xy
| j } Wn t k
r| j } Yn X| j } d } t
| t r-t j | j r-| j d k r-t j | j } | d k r| \ } } | d k rd | | | f } qtd
| | | f } nG | d k rX| j } d | | | f } n | j } d | | | f } | S) NrE r> r r z{}()Fz
{} runningr z%s done, defined at %s:%sz %s running, defined at %s:%sz%s running at %s:%s)r r' hasattrr- r: r rA rD rS r= rQ r# r r r Z_format_callbackr> rE r< rF co_filenamer% rZ Z_get_function_sourcef_linenoco_firstlineno)
r! Z coro_nameZrunningr Z coro_codeZ
coro_framefilenamelinenosourcer1 r
r
r r/ sn
r/ )-__all__r[ r% Zopcodeosr* r( typesrG r r r logr Zopmapr8 flagsignore_environmentboolenvirongetr] r r^
CoroutineTypeZ_types_CoroutineTyperS r rY collections.abcr Z
_CoroutineABCr rR ImportErrorr" rO r$ r# objectr_
GeneratorTyper` r r/ r
r
r
r <module> sX
i :