U
vi @ sf d dl mZmZmZ d dlmZmZ d dlmZ edZ ej
eee gee f dddZ dgZ dS ) )CallableOptionalTypeVar)
Observableabc)ObserveOnObserver_T) schedulerreturnc s t t t t d fdd }|S )N)sourcer
c s, dt jt tt j d fdd
}t|S )a Wraps the source sequence in order to run its observer
callbacks on the specified scheduler.
This only invokes observer callbacks on a scheduler. In case
the subscription and/or unsubscription actions have
side-effects that require to be run on a scheduler, use
subscribe_on.
Args:
source: Source observable.
Returns:
Returns the source sequence whose observations happen on
the specified scheduler.
NZobserverZsubscribe_schedulerc s j t | |dS )Nr ) subscriber r )r r O/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_observeon.pyr s z2observe_on_..observe_on..subscribe)N)r Z ObserverBaser r
SchedulerBaser )r r r
)r r
observe_on s z observe_on_..observe_on)r r )r r r r
r observe_on_ s r N)
typingr r r Z reactivexr r Zreactivex.observerr r r r __all__r r r r s "