python/biopro/util/__pycache__/promise.cpython-37.opt-2.pyc

B
ò0Àa�ã@sÞddlmZddlmZmZmZmZmZmZm	Z	ddgZ
dZdZes~ddl
Z
yee
 dd¡ƒdkZWnek
r|dZYnXedƒZed	ƒZeegdfZeegdfZeeefZGd
d„deƒZGdd„deeƒZdS)é)Ú	Condition)ÚTupleÚListÚCallableÚoverloadÚTypeVarÚGenericÚOptionalÚPromiseÚPromiseCancelInterruptFNZ
DEBUG_PROMISEÚTÚRc@seZdZdS)rN)Ú__name__Ú
__module__Ú__qualname__©rrú8/home/pi/wisetopdataserver/python/biopro/util/promise.pyrxsc@s&eZdZdZd(edœdd„Zeedœdd„ƒZeedœd	d
„ƒZ	e
dœdd„Zee
dœd
d„Ze
dœdd„Ze
dœdd„Zdd„Zed)ee
gefeee
gdfddœdd„ƒZed*ee
gdfeee
gdfddœdd„ƒZd+dd„Zee
ddœdd „ƒZee
dd!œd"d#„ƒZd$d%„Zd&d'„ZdS),r
rN)ÚnamecCs\|dkr$tj}tjd7_t|ƒ}||_d|_d|_d|_tƒ|_g|_	t
rXt|dƒdS)NéFÚcreate)r
ÚCOUNTERÚstrÚ_Promise__nameÚ_Promise__resolveÚ_Promise__valueÚ_Promise__errorrÚ_Promise__conditionÚ_Promise__callbackÚ_DEBUG_PROMISEÚprint)ÚselfrÚirrrÚ__init__‚szPromise.__init__)ÚreturncCs
|jdkS)NT)r)r rrrÚis_resolved–szPromise.is_resolvedcCst|jtƒS)N)Ú
isinstancerr)r rrrÚis_canceledžszPromise.is_canceledc	CsZxT|jdk	r|j‚|jr6t|jtƒr.|j ¡S|jSq|j�|j ¡WdQRXqWdS)N)rrr%rr
ÚgetrÚwait)r rrrr'¦s

zPromise.getcCs|jS)N)r)r rrrÚ	get_error»szPromise.get_error)Úvaluec	Csf|jrtdƒ‚trt|d|ƒ|j�d|_||_|j ¡WdQRXx|jD]\}}||ƒqNWdS)Nzpromise has resolvedÚcompleteT)rÚRuntimeErrorrrrrÚ
notify_allr)r r*ÚcÚ_rrrr+ÂszPromise.complete)Úec	Csf|jrtdƒ‚trt|d|ƒ|j�d|_||_|j ¡WdQRXx|jD]\}}||ƒqNWdS)Nzpromise has resolvedÚrejectT)rr,rrrrr-r)r r0r/Újrrrr1ÖszPromise.rejectc	Csj|jrtdƒ‚trt|dƒ|j�"d|_tƒ|_}|j ¡WdQRXx|jD]\}}||ƒqRWdS)Nzpromise has resolvedÚcancelT)	rr,rrrrrr-r)r r0r/r2rrrr3ês
zPromise.cancelz
Promise[R])ÚfÚpromise_nameÚ	on_rejectr#cCsdS)Nr)r r4r5r6rrrÚthenþszPromise.thencCsdS)Nr)r r4r5r6rrrr7scs |dkr ˆjdttˆjƒƒ}t|ƒ‰tdœ‡‡‡fdd„‰tdœ‡‡‡‡fdd„}ˆj |ˆf¡trvt	ˆdˆƒˆj
dk	rŒˆˆj
ƒnˆjrœ|ˆjƒˆS)	Nz-then:)r0cs4trtˆdˆd|ƒˆ |¡ˆdk	r0ˆˆjƒdS)NÚ_rejectÚwith)rrr1r)r0)r6Úpr rrr8s

zPromise.then.<locals>._reject)r*c
s€trtˆdˆd|ƒy2ˆ|ƒ}tr2tˆdˆd|ƒt|tƒrD| ¡}Wn*tk
rp}zˆ|ƒWdd}~XYnXˆ |¡dS)NÚ_resolver9r')rrr%r
r'Ú
BaseExceptionr+)r*Úqr0)r8r4r:r rrr; s
zPromise.then.<locals>._resolver7)
rrÚlenrr
r<rÚappendrrrrr)r r4r5r6r;r)r8r4r6r:r rr7
s	

z
Promise[T])r*r#cCstƒ}| |¡|S)N)r
r+)Úclsr*r:rrrÚresolved>s