U
vi @ sT d dl m Z d dlmZmZ d dlmZ d dlmZ ddlm Z G dd de
Z d S )
)datetime)AnyOptional)abc)SingleAssignmentDisposable ) Schedulerc @ s e Zd Zeee eje eddddZ ddddZ
dddd Z e dd
d Z
d e d d
dZd e d ddZee d ddZdS )
ScheduledItemN) schedulerstateactionduetimereturnc C s$ || _ || _|| _|| _t | _d S N)r
r r r
r
disposable)selfr
r r r
r R/opt/alt/python38/lib/python3.8/site-packages/reactivex/scheduler/scheduleditem.py__init__ s
zScheduledItem.__init__)r c C s | j j| j| jd}|| j_d S )N)r )r
Z
invoke_actionr r r )r retr r r invoke s zScheduledItem.invokec C s | j dS )zdCancels the work item by disposing the resource returned by
invoke_core as soon as possible.N)r Zdisposer r r r cancel s zScheduledItem.cancelc C s | j jS r )r Z is_disposedr r r r is_cancelled" s zScheduledItem.is_cancelled)otherr c C s | j |j k S r r
r r r r r __lt__% s zScheduledItem.__lt__c C s | j |j kS r r r r r r __gt__( s zScheduledItem.__gt__c C s, z| j |j kW S tk
r& t Y S X d S r )r
AttributeErrorNotImplementedr r r r __eq__+ s zScheduledItem.__eq__)__name__
__module__ __qualname__r r r r ZScheduledActionr r r r boolr r r r! r r r r r
s
r N) r typingr r Z reactivexr Zreactivex.disposabler r
r objectr r r r r s