🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 16:37:23 | 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: _merge.cpython-38.pyc
Read Only
U v�iA � @ s� d dl mZ d dlmZmZmZmZmZ d dlZd dlm Z m Z m Z mZ d dl m Z mZ d dlmZ ed�Zdd�e e ee ee e e ge e f d �d d �Zee e e ge e f d �d d�Zd dgZdS )� )�Future)�Callable�List�Optional�TypeVar�UnionN)� Observable�abc� from_future�typing)�CompositeDisposable�SingleAssignmentDisposable)� synchronized�_T)�max_concurrent)�sourcesr �returnc s& t t t t t d�� �fdd� }|S )N��sourcer c sL �dkr t � g�� }tj|� S dtjt ttj d��� fdd� }t|�S )a� Merges an observable sequence of observable sequences into an observable sequence, limiting the number of concurrent subscriptions to inner sequences. Or merges two observable sequences into a single observable sequence. Examples: >>> res = merge(sources) Args: source: Source observable. Returns: The observable sequence that merges the elements of the inner sequences. N��observer� schedulerc s� dg� t � �dg�g �tt d�� �������fdd� �tt d d�� ���fdd� }� ��fd d �}���j|�j|�d �� �S ) Nr F)�xsc sj t � � ��� � t�j�������� fdd��}t�j��j�}t�j��j�}| j|||�d�� _d S )Nc sR �� �� �r"��d�} �| � n,� d d8 < �d rN� d dkrN��� d S �Nr � )�remove�pop� on_completed)�s)� active_count�group� is_stoppedr �queue� subscribe� subscription� �K/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_merge.pyr 1 s zQmerge_.<locals>.merge.<locals>.subscribe.<locals>.subscribe.<locals>.on_completed�r )r �addr �lock�on_next�on_errorr# � disposable)r r r* r+ )r r r! r r" r r r# )r$ r& r# - s �z;merge_.<locals>.merge.<locals>.subscribe.<locals>.subscribe)� inner_sourcer c s< �st �� d �k r.� d d7 < �| � n ��| � d S r )�AssertionError�append�r- )r r r" r# r% r& r* B s z9merge_.<locals>.merge.<locals>.subscribe.<locals>.on_nextc s d�d< � d dkr �� � d S )NTr )r r% )r r! r r% r& r J s z>merge_.<locals>.merge.<locals>.subscribe.<locals>.on_completedr' )r r r r( r# r+ )r r r* r )r r )r r r! r r" r r# r& r# $ s $ ��z(merge_.<locals>.merge.<locals>.subscribe)N) �tuple� reactivex�merger � ObserverBaser r � SchedulerBaser )r Zsources_r# �r r �r r& r3 s ��2zmerge_.<locals>.merge�r r )r r r3 r% r6 r& �merge_ s "Ir9 )r c C s t t t t t d�dd�} | S )Nr c s* dt jt tt j d�� fdd� }t|�S )aD Partially applied merge_all operator. Merges an observable sequence of observable sequences into an observable sequence. Args: source: Source observable to merge. Returns: The observable sequence that merges the elements of the inner sequences. Nr c sl t � � dg�t� }� �|� ttt df d�� ����fdd� }� ��fdd�}�j|�j|�d�|_� S ) NFz Future[_T]r0 c s~ t � � ��� � t| t�r"t| �n| } t�j��� ��fdd��}t�j��j�}t�j��j�}| j |||�d�}|� _ d S )Nc s* � � �� �d r&t� �dkr&��� d S r )r �lenr r% )r �inner_subscriptionr! r r% r& r } s zWmerge_all_.<locals>.merge_all.<locals>.subscribe.<locals>.on_next.<locals>.on_completedr' ) r r( � isinstancer r r r) r* r+ r# r, )r- r r* r+ r$ )r r! r r r )r; r& r* s s" � � �zAmerge_all_.<locals>.merge_all.<locals>.subscribe.<locals>.on_nextc s d�d< t � �dkr ��� d S )NTr r )r: r r% )r r! r r% r& r � s zFmerge_all_.<locals>.merge_all.<locals>.subscribe.<locals>.on_completedr' ) r r r( r r r r# r+ r, )r r �mr* r r7 )r r! r r r& r# j s & �z0merge_all_.<locals>.merge_all.<locals>.subscribe)N)r r4 r r r5 r )r r# r% r7 r& � merge_all\ s ��*z merge_all_.<locals>.merge_allr8 )r> r% r% r& � merge_all_[ s :r? )�asyncior r r r r r r r2 r r r Zreactivex.disposabler r Zreactivex.internalr r �intr9 r? �__all__r% r% r% r& �<module> s � � O$>
💾 Save Changes
❌ Cancel