🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 09:22:35 | 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: fromiterable.cpython-38.pyc
Read Only
U v�it � @ sx d dl mZmZmZmZ d dlmZmZ d dlm Z m Z d dl m Z ed�Z d ee eej ee d�dd �Zd gZdS ) � )�Any�Iterable�Optional�TypeVar)� Observable�abc)�CompositeDisposable� Disposable)�CurrentThreadScheduler�_TN)�iterable� scheduler�returnc s0 dt jt tt j t jd�� �fdd� }t|�S )aJ Converts an iterable to an observable sequence. Example: >>> from_iterable([1,2,3]) Args: iterable: A Python iterable scheduler: An optional scheduler to schedule the values on. Returns: The observable sequence whose elements are pulled from the given iterable sequence. N)�observer� scheduler_r c sd �p|pt �� }t���d� dtjtd d�� ��fdd� }d d�� fdd� }t|�}t|�|�|�S ) NF)�_�__r c sh z � st ��}��|� qW nF tk r8 ��� Y n, tk rb } z��|� W 5 d }~X Y nX d S )N)�nextZon_next� StopIterationZ on_completed� ExceptionZon_error)r r �value�error��disposed�iteratorr � �R/opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/fromiterable.py�action" s z1from_iterable_.<locals>.subscribe.<locals>.action)r c s d� d S )NTr r )r r r �dispose. s z2from_iterable_.<locals>.subscribe.<locals>.dispose)N) r Z singleton�iterr � SchedulerBaser r r Zschedule)r r Z _schedulerr r Zdisp�r r r r � subscribe s z!from_iterable_.<locals>.subscribe)N)r Z ObserverBaser r r ZDisposableBaser )r r r" r r! r �from_iterable_ s � �r# )N)�typingr r r r Z reactivexr r Zreactivex.disposabler r Zreactivex.schedulerr r r r# �__all__r r r r �<module> s � � .
💾 Save Changes
❌ Cancel