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_..subscribe..action)r c s d‰ d S )NTr r )r r r Údispose. s z2from_iterable_..subscribe..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_..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 Ú s ÿ þ .