U
vi @ s d dl mZ d dlmZmZmZmZmZ d dlm Z m
Z
m Z d dl m
Z
mZ edZee e df ee e ge e f ddd Zd gZd
S ) )Future)CallableListOptionalTypeVarUnion)
Observableabc from_future)CompositeDisposableSingleAssignmentDisposable_Tz
Future[_T]) right_sourcereturnc s8 t | trt| n| tt tt d fdd }|S )N) left_sourcer c s0 dt jt tt j t jd fdd
}t|S )N)observer schedulerr c
s d g ddt t fdd fddtd d fdd }td d
fd d }d d
fdd }j||||d}|_td d fdd }td d
fdd }d d
fdd } j||||d} | _tS )NLRc s d s d< d S Nr Zdispose )choice left_choiceright_subscriptionr I/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_amb.py choice_left s z9amb_..amb..subscribe..choice_leftc s d s d< d S r r r )r left_subscription right_choicer r choice_right# s z:amb_..amb..subscribe..choice_right)valuer c s2 j W 5 Q R X d kr.| d S r lockZon_nextr r r r r r r r on_next_left( s z:amb_..amb..subscribe..on_next_left)errr c s2 j W 5 Q R X d kr.| d S r r" Zon_errorr& r$ r r
on_error_left. s z;amb_..amb..subscribe..on_error_left)r c s0 j W 5 Q R X d kr, d S r r" Z on_completedr r$ r r on_completed_left4 s z?amb_..amb..subscribe..on_completed_left)r c s2 j W 5 Q R X d kr.| d S r r! r# r r r r r r r
send_right? s z8amb_..amb..subscribe..send_rightc s2 j W 5 Q R X d kr.| d S r r' r( r, r r on_error_rightE s z.amb..subscribe..on_error_rightc s0 j W 5 Q R X d kr, d S r r* r r, r r on_completed_rightK s z@amb_..amb..subscribe..on_completed_right)r r
Exception subscribeZ
disposabler )
r r r% r) r+ Zleft_dr- r. r/ Zright_d)r obs)r r r r r r r r r r1 s8 z$amb_..amb..subscribe)N)r Z ObserverBaser
r Z
SchedulerBaseZDisposableBaser )r r1 r2 )r r amb s Czamb_..amb)
isinstancer r
r r
)r r4 r r3 r amb_
s
Fr6 N)asyncior typingr r r r r Z reactivexr r r
Zreactivex.disposabler r r
r6 __all__r r r r s R