🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 20:04:59 | PHP 8.2.32
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
operators
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/__pycache__
🔄 Refresh
✏️
Editing: _amb.cpython-38.pyc
Read Only
U v�i � @ s� d dl mZ d dlmZmZmZmZmZ d dlm Z m Z m Z d dl m Z mZ ed�Zee e df ee e ge e f d�dd �Zd gZd S ) � )�Future)�Callable�List�Optional�TypeVar�Union)� Observable�abc� from_future)�CompositeDisposable�SingleAssignmentDisposable�_Tz Future[_T])� right_source�returnc s8 t | t�rt| �� 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� d�d�t � �t � �� ��fdd��� ��fdd��td d�� ����fdd � }td d �� ����fd d � }d d �� ����fdd� }�j||||d�}|�_td d�� ����fdd� }td d �� ����fdd� }d d �� ����fdd� }� j||||d�} | �_t���S )N�L�Rc s � d s�� d< �� � d S �Nr �Zdispose� )�choice� left_choice�right_subscriptionr �I/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_amb.py� choice_left s z9amb_.<locals>.amb.<locals>.subscribe.<locals>.choice_leftc s � d s�� d< �� � d S r r r )r �left_subscription� right_choicer r � choice_right# s z:amb_.<locals>.amb.<locals>.subscribe.<locals>.choice_right)�valuer c s2 �j � �� W 5 Q R X � d �kr.��| � d S r ��lockZon_next�r �r r r r r r r � on_next_left( s z:amb_.<locals>.amb.<locals>.subscribe.<locals>.on_next_left)�errr c s2 �j � �� W 5 Q R X � d �kr.��| � d S r �r" Zon_error�r& r$ r r � on_error_left. s z;amb_.<locals>.amb.<locals>.subscribe.<locals>.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_.<locals>.amb.<locals>.subscribe.<locals>.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_.<locals>.amb.<locals>.subscribe.<locals>.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_.<locals>.amb.<locals>.subscribe.<locals>.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_.<locals>.amb.<locals>.subscribe.<locals>.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_.<locals>.amb.<locals>.subscribe)N)r Z ObserverBaser r Z SchedulerBaseZDisposableBaser )r r1 �r2 )r r �amb s ��Czamb_.<locals>.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 �<module> s � R
💾 Save Changes
❌ Cancel