U
vi @ s> d dl mZ d dlmZmZ d dlmZ G dd dejZdS ) )RLock)AnyList)abcc s e Zd ZdZed fdd ZejddddZeje dd d
Z
dd d d
Z dd ddZ eje dddZ
eej d ddZed ddZeed ddZ ZS )CompositeDisposablezIRepresents a group of disposable resources that are disposed
together)argsc sH |r t |d tr |d | _n
t|| _d| _t | _tt| d S )Nr F)
isinstancelist
disposable is_disposedr locksuperr __init__)selfr __class__ Y/opt/alt/python38/lib/python3.8/site-packages/reactivex/disposable/compositedisposable.pyr s
z CompositeDisposable.__init__N)itemreturnc C s> d}| j | jrd}n | j| W 5 Q R X |r:| dS )zAdds a disposable to the CompositeDisposable or disposes the
disposable if the CompositeDisposable is disposed
Args:
item: Disposable to add.FTN)r r r
appenddisposer r Zshould_disposer r r add s zCompositeDisposable.addc C sJ | j r
dS d}| j || jkr0| j| d}W 5 Q R X |rF| |S )z_Removes and disposes the first occurrence of a disposable
from the CompositeDisposable.FT)r r r
remover r r r r r & s
zCompositeDisposable.remove)r c C sD | j r
dS | j d| _ | j}g | _W 5 Q R X |D ] }| q2dS )zMDisposes all disposable in the group and removes them from
the group.NT)r r r
r )r current_disposableZdispr r r r 8 s zCompositeDisposable.disposec C s4 | j | j}g | _W 5 Q R X |D ] }| q"dS )zRemoves and disposes all disposable from the
CompositeDisposable, but does not dispose the
CompositeDisposable.N)r r
r )r r r
r r r clearG s
zCompositeDisposable.clearc C s
|| j kS )zDetermines whether the CompositeDisposable contains a specific
disposable.
Args:
item: Disposable to search for
Returns:
True if the disposable was found; otherwise, Falser
)r r r r r containsS s
z CompositeDisposable.containsc C s | j d d S Nr r r r r to_list_ s zCompositeDisposable.to_listc C s
t | jS r lenr
r r r r __len__b s zCompositeDisposable.__len__c C s
t | jS r r" r r r r lengthe s zCompositeDisposable.length)__name__
__module__ __qualname____doc__r r r DisposableBaser boolr r r r r r! intr$ propertyr%
__classcell__r r r r r s
r N) threadingr typingr r Z reactivexr r* r r r r r s