✏️ Editing: defer.cpython-38.pyc Read Only

����v�i�����������������������@���s����d�dl�mZ�d�dlmZmZmZmZ�d�dlmZm	Z	m
Z
mZ�d�dlm
Z
�ed�Zee	jgeee�df�f�ee�d�dd	�Zd	gZd
S�)�����)�Future)�Callable�Optional�TypeVar�Union)�
Observable�abc�from_future�throw)�ImmediateScheduler�_Tz
Future[_T])�factory�returnc��������������������s.���dt�jt�tt�j�t�jd���fdd�
}t|�S�)a��Returns an observable sequence that invokes the specified factory
    function whenever a new observer subscribes.

Example:
        >>> res = defer(lambda scheduler: of(1, 2, 3))

Args:
        observable_factory: Observable factory function to invoke for
        each observer that subscribes to the resulting sequence. The
        factory takes a single argument, the scheduler used.

Returns:
        An observable sequence whose observers trigger an invocation
        of the given observable factory function.
    N)�observer�	schedulerr���c��������������
������sn���z��|pt�����}W�n4�tk
rH�}�zt|��|���W�Y��S�d�}~X�Y�nX�t|t�r\t|�n|}|j|�|d�S�)N)r���)r���Z	singleton�	Exceptionr
����	subscribe�
isinstancer���r	���)r���r����result�ex�r
������K/opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/defer.pyr������s����$zdefer_.<locals>.subscribe)N)r���ZObserverBaser���r����
SchedulerBaseZDisposableBaser���)r
���r���r���r���r����defer_
���s��������r���N)�asyncior����typingr���r���r���r���Z	reactivexr���r���r	���r
���Zreactivex.schedulerr���r���r���r����__all__r���r���r���r����<module>���s����!

🔐 Sid Gifari File Manager Pro