U
vâ’i¥ ã @ sR d dl mZ d dlmZmZ d dlmZ edƒZee ee dœdd„ZdgZ dS ) é )ÚTypeVar)Ú
ObservableÚnever)Ú operatorsÚ_T)ÚsourcesÚreturnc G s< t ƒ }tt tt tt dœdd„}| D ]}|||ƒ}q(|S )zåPropagates the observable sequence that reacts first.
Example:
>>> winner = amb(xs, ys, zs)
Returns:
An observable sequence that surfaces any of the given sequences,
whichever reacted first.
)ÚpreviousÚcurrentr c S s t | ¡|ƒS )N)Ú_Zamb)r r
© r úI/opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/amb.pyÚfunc s zamb_..func)r r r )r Úaccr Úsourcer r r
Úamb_ s
r N)
Útypingr Z reactivexr r r r r r Ú__all__r r r r
Ú s