U
vâ’iÐ ã @ sr d dl mZmZmZmZ d dlmZmZ d dlm Z m
Z
m Z edƒZ ej
eee gee f dœdd„ZdgZdS ) é )ÚAnyÚCallableÚOptionalÚTypeVar)Ú
ObservableÚabc)ÚScheduledDisposableÚSerialDisposableÚSingleAssignmentDisposableÚ_T)Ú schedulerÚreturnc s t t t t dœ‡ fdd„ }|S )N)Úsourcer
c s, dt jt tt j dœ‡‡ fdd„
}t|ƒS )a× Subscribe on the specified scheduler.
Wrap the source sequence in order to run its subscription and
unsubscription logic on the specified scheduler. This operation
is not commonly used; see the remarks section for more
information on the distinction between subscribe_on and
observe_on.
This only performs the side-effects of subscription and
unsubscription on the specified scheduler. In order to invoke
observer callbacks on a scheduler, use observe_on.
Args:
source: The source observable..
Returns:
The source sequence whose subscriptions and
un-subscriptions happen on the specified scheduler.
N)ÚobserverÚ_c sB t ƒ }tƒ ‰ |ˆ _dtjtt dœ‡ ‡‡fdd„
}ˆ |¡|_ˆ S )N©r Ústatec s t | ˆ ˆ¡ƒˆ _d S )N)r Ú subscribeÚ
disposabler )Údr r © úQ/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_subscribeon.pyÚaction, s ÿzFsubscribe_on_..subscribe_on..subscribe..action)N)r
r r r Ú
SchedulerBaser r Zschedule)r r Úmr )r r )r r r r % s z6subscribe_on_..subscribe_on..subscribe)N)r Z ObserverBaser r r r )r r ©r )r r Ú subscribe_on s ÿ ÿz#subscribe_on_..subscribe_on)r r )r r r r r Ú
subscribe_on_
s &r N)Útypingr r r r Z reactivexr r Zreactivex.disposabler r r
r r r Ú__all__r r r r Ú s þ ,