🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 14:22:12 | 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: _toiterable.cpython-38.pyc
Read Only
U v�i� � @ s^ d dl mZmZmZmZ d dlmZmZ ed�Zeee geee f d�dd�Z dgZ dS )� )�Callable�List�Optional�TypeVar)� Observable�abc�_T)�returnc C s t t t tt d�dd�} | S )N)�sourcer c s. dt jtt tt j d�� fdd� }t|�S )z�Creates an iterable from an observable sequence. Returns: An observable sequence containing a single element with an iterable containing all the elements of the source sequence. N)�observer� schedulerc s8 g �t d��fdd� }� �fdd�}�j|� j||d�S )N��itemc s � � | � d S �N)�appendr )�queue� �P/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_toiterable.py�on_next s zEto_iterable_.<locals>.to_iterable.<locals>.subscribe.<locals>.on_nextc s � � �� g �� �� d S r )r � on_completedr �r r r r r s zJto_iterable_.<locals>.to_iterable.<locals>.subscribe.<locals>.on_completed)r )r � subscribeZon_error)r r r r �r r r r s �z4to_iterable_.<locals>.to_iterable.<locals>.subscribe)N)r Z ObserverBaser r r Z SchedulerBaser )r r r r r � to_iterable s � �z!to_iterable_.<locals>.to_iterable)r r r )r r r r � to_iterable_ s r N) �typingr r r r Z reactivexr r r r �__all__r r r r �<module> s $$
💾 Save Changes
❌ Cancel