U
vâ’i} ã @ sF d dl mZ d dlmZ d dlmZ ddlmZ G dd„ dejƒZ dS ) é )ÚRLock)ÚAny)Úabcé )ÚSingleAssignmentDisposablec sN e Zd ZdZejejddœ‡ fdd„ Zee dœdd„ƒZ
ddœd d
„Z ‡ Z S ) ÚScheduledDisposablezkRepresents a disposable resource whose disposal invocation will
be scheduled on the specified SchedulerN)Ú schedulerÚ
disposableÚreturnc s, || _ tƒ | _|| j_tƒ | _tƒ ¡ dS )z}Initializes a new instance of the ScheduledDisposable class
that uses a Scheduler on which to dispose the disposable.N)r r r r ÚlockÚsuperÚ__init__)Úselfr r ©Ú __class__© úY/opt/alt/python38/lib/python3.8/site-packages/reactivex/disposable/scheduleddisposable.pyr
s
z ScheduledDisposable.__init__)r
c C s | j jS )N)r Ú is_disposed©r r r r r s z ScheduledDisposable.is_disposedc s( t jtddœ‡ fdd„ }ˆ j |¡ dS )z:Disposes the wrapped disposable on the provided scheduler.N)r Ústater
c s ˆ j ¡ dS )zScheduled dispose actionN)r Údispose)r r r r r Úaction! s z+ScheduledDisposable.dispose..action)r Ú
SchedulerBaser r Zschedule)r r r r r r s zScheduledDisposable.dispose)
Ú__name__Ú
__module__Ú __qualname__Ú__doc__r r ÚDisposableBaser
ÚpropertyÚboolr r Ú
__classcell__r r r r r s þ
r N)
Ú threadingr Útypingr Z reactivexr Zsingleassignmentdisposabler r r r r r r Ú s