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

����v�iC����������������������@���s`���d�dl�mZmZmZ�d�dlmZmZmZ�ed�Zdeg�ef�eej	�ee�d�dd�Z
dgZdS�)	�����)�Callable�Optional�TypeVar)�
Observable�abc�to_async�_TN)�func�	scheduler�returnc�����������������C���s���t�|�|���S�)a��Invokes the specified function asynchronously on the specified
    scheduler, surfacing the result through an observable sequence.

Example:
        >>> res = reactivex.start(lambda: pprint('hello'))
        >>> res = reactivex.start(lambda: pprint('hello'), rx.Scheduler.timeout)

Args:
        func: Function to run asynchronously.
        scheduler: [Optional] Scheduler to run the function on. If
            not specified, defaults to Scheduler.timeout.

Remarks:
        The function is called immediately, not during the subscription
        of the resulting sequence. Multiple subscriptions to the
        resulting sequence can observe the function's result.

Returns:
        An observable sequence exposing the function's result value,
        or an exception.
    )r���)r	���r
�����r����K/opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/start.py�start_���s����r���)N)�typingr���r���r���Z	reactivexr���r���r���r���Z
SchedulerBaser����__all__r���r���r���r
����<module>���s�����
��

🔐 Sid Gifari File Manager Pro