🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 09:18:44 | PHP 8.2.32
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
observable
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/__pycache__
🔄 Refresh
✏️
Editing: forkjoin.cpython-38.pyc
Read Only
U v�i� � @ sf d dl mZmZmZmZmZ d dlmZmZ d dl m Z m Z ee eeedf d�dd�Z dgZ dS ) � )�Any�List�Optional�Tuple�cast)� Observable�abc)�CompositeDisposable�SingleAssignmentDisposable.)�sources�returnc s@ �d � dt jttdf tt j t jd�� �fdd� }t|�S )a� Wait for observables to complete and then combine last values they emitted into a tuple. Whenever any of that observables completes without emitting any value, result sequence will complete at that moment as well. Examples: >>> obs = reactivex.fork_join(obs1, obs2, obs3) Returns: An observable sequence containing the result of combining last element from each source in given sequence. r N.)�observer� schedulerr c s� t ��}d g| �dg| �dg| �td d�����fdd� � ttd �g| �td d�� �������fdd� }t|�D ] }||� qzt��S )NF)�ir c sP d�| < � | s �� � d S t��rLt� �rD��t��� �� � n�� � d S �NT)� on_completed�all�on_next�tuple�r )� has_value�is_doner �values� �N/opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/forkjoin.py�done s z+fork_join_.<locals>.subscribe.<locals>.donec s\ t � �� < td d��� ��fdd� }d d��� �fdd� }�� j|�j|�d��� _d S )N)�valuer c s& �j � | ��< d� �< W 5 Q R X d S r ��lock)r )r r �parentr r r r 4 s zBfork_join_.<locals>.subscribe.<locals>._subscribe.<locals>.on_next)r c s �j � � �� W 5 Q R X d S )Nr r )r r r r r r 9 s zGfork_join_.<locals>.subscribe.<locals>._subscribe.<locals>.on_completed)r )r r � subscribeZon_errorZ disposable)r r r )r r r r r r � subscriptionsr r r � _subscribe1 s �z1fork_join_.<locals>.subscribe.<locals>._subscribe)�len�intr r �ranger )r r �nr" r �r r )r r r r r r! r r r s ��" z fork_join_.<locals>.subscribe)N)r Z ObserverBaser r r Z SchedulerBaseZDisposableBaser )r r r r' r � fork_join_ s ��/r( N)�typingr r r r r Z reactivexr r Zreactivex.disposabler r r( �__all__r r r r �<module> s A
💾 Save Changes
❌ Cancel