🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 02:17:13 | PHP 8.2.32
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
disposable
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/disposable/__pycache__
🔄 Refresh
✏️
Editing: refcountdisposable.cpython-38.pyc
Read Only
U v�i� � @ sD d dl mZ d dlmZ d dlmZ ddlmZ G dd� de�ZdS ) � )�RLock)�Optional)�DisposableBase� )� Disposablec sf e Zd ZdZG dd� de�Zedd�� fdd�Zdd�d d �Zdd�dd�Ze ed�d d��Z � ZS )�RefCountDisposablez�Represents a disposable resource that only disposes its underlying disposable resource when all dependent disposable objects have been disposed.c @ s* e Zd Zddd�dd�Zdd�dd�ZdS ) z"RefCountDisposable.InnerDisposabler N)�parent�returnc C s || _ d| _t� | _d S )NF)r �is_disposedr �lock��selfr � r �X/opt/alt/python38/lib/python3.8/site-packages/reactivex/disposable/refcountdisposable.py�__init__ s z+RefCountDisposable.InnerDisposable.__init__�r c C s2 | j � | j}d | _W 5 Q R X |d k r.|�� d S )N)r r �releaser r r r �dispose s z*RefCountDisposable.InnerDisposable.dispose)�__name__� __module__�__qualname__r r r r r r �InnerDisposable s r N)� disposabler c s. || _ d| _d| _t� | _d| _t� �� dS )zaInitializes a new instance of the RefCountDisposable class with the specified disposable.Fr N)�underlying_disposable�is_primary_disposedr r r �count�superr )r r �� __class__r r r s zRefCountDisposable.__init__r c C sR | j r dS d}| j�$ | js4d| _| js4d| _ | j}W 5 Q R X |dk rN|�� dS )zaDisposes the underlying disposable only when all dependent disposable have been disposed.NT)r r r r r r )r r r r r r ( s zRefCountDisposable.disposec C sV | j r d S d}| j�* | jd8 _| js:| jr:d| _ d}W 5 Q R X |rR| j�� d S )NFr T)r r r r r r )r Zshould_disposer r r r : s zRefCountDisposable.releasec C sN | j �> | jr t� W 5 Q R � S | jd7 _| �| �W 5 Q R � S Q R X dS )znReturns a dependent disposable that when disposed decreases the refcount on the underlying disposable.r N)r r r r r )r r r r r H s zRefCountDisposable.disposable)r r r �__doc__r r r r r �propertyr � __classcell__r r r r r s r N) � threadingr �typingr Z reactivex.abcr r r r r r r r �<module> s
💾 Save Changes
❌ Cancel