U
vâ’iž ã @ sŒ d dl mZmZmZmZ d dlmZmZ d dlmZ d dl
m Z d dl m
Z
edƒZd edef eej edee f d œd
d „Zd gZdS )
é )ÚAnyÚCallableÚOptionalÚTypeVar)Ú
ObservableÚabc)Ú operators)ÚTimeoutScheduler)Ú AsyncSubjectÚ_TN.)ÚfuncÚ schedulerÚreturnc s* |p
t ¡ ‰ ttt dœ‡ ‡fdd„ }|S )a² Converts the function into an asynchronous function. Each
invocation of the resulting asynchronous function causes an
invocation of the original synchronous function on the specified
scheduler.
Examples:
res = reactivex.to_async(lambda x, y: x + y)(4, 3)
res = reactivex.to_async(lambda x, y: x + y, Scheduler.timeout)(4, 3)
res = reactivex.to_async(lambda x: log.debug(x), Scheduler.timeout)('hello')
Args:
func: Function to convert to an asynchronous function.
scheduler: [Optional] Scheduler to run the function on. If not
specified, defaults to Scheduler.timeout.
Returns:
Aynchronous function.
)Úargsr c s< t ƒ ‰dtjtd dœ‡ ‡‡fdd„
}ˆ |¡ ˆ t ¡ ¡S )N)r
Ústater c
sV z ˆˆ Ž }W n2 t k
r> } zˆ |¡ W Y ¢d S d }~X Y nX ˆ |¡ ˆ ¡ d S )N)Ú ExceptionZon_errorZon_nextZ on_completed)r
r ÚresultÚex)r r Úsubject© úM/opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/toasync.pyÚaction& s
z*to_async_..wrapper..action)N)r
r Ú
SchedulerBaser ZscheduleÚpipeÚopsZ
as_observable)r r ©Z
_schedulerr )r r r Úwrapper# s
zto_async_..wrapper)r Z singletonr r r )r r
r r r r Ú to_async_ s r )N)Útypingr r r r Z reactivexr r r r Zreactivex.schedulerr Zreactivex.subjectr
r r r Ú__all__r r r r Ú s ÿ
þ +