U
vâ’iC ã @ s` d dl mZmZmZ d dlmZmZmZ edƒZdeg ef eej ee dœdd„Z
dgZ dS ) é )Ú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
Ú s ÿ
þ