U
vi @ s d dl mZ d dlmZmZmZmZ d dlmZm Z m
Z
m Z d dl m
Z
edZee jgeee df f ee ddd Zd gZd
S ) )Future)CallableOptionalTypeVarUnion)
Observableabc from_futurethrow)ImmediateScheduler_Tz
Future[_T])factoryreturnc 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|tr\t|n|}|j| |dS )N)r )r Z singleton Exceptionr
subscribe
isinstancer r )r r resultexr
K/opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/defer.pyr s $zdefer_..subscribe)N)r Z ObserverBaser 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 s !