U
vil @ s\ d dl mZ d dlmZ d dlmZ d dlmZ d dlmZ d dl m
Z
G dd deZ d S )
)RLock)Optional)typing)DisposableBase)noop)Actionc s> e Zd ZdZd eej dd fdd
ZddddZ Z S )
DisposablezMain disposable classN)actionreturnc s& d| _ |p t| _t | _t dS )a[ Creates a disposable object that invokes the specified
action when disposed.
Args:
action: Action to run during the first call to dispose.
The action is guaranteed to be run at most once.
Returns:
The disposable object that runs the given action upon
disposal.
FN) is_disposedr r r locksuper__init__)selfr __class__ P/opt/alt/python38/lib/python3.8/site-packages/reactivex/disposable/disposable.pyr
s
zDisposable.__init__)r
c C s6 d}| j | js d}d| _W 5 Q R X |r2| dS )z+Performs the task of cleaning up resources.FTN)r r r )r disposer r r r ! s zDisposable.dispose)N)
__name__
__module__ __qualname____doc__r r r r r
__classcell__r r r r r
s r N) threadingr r r Z reactivexZ
reactivex.abcr Zreactivex.internalr Zreactivex.typingr r r r r r s