🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-09 02:04:31 | PHP 8.2.33
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
subject
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/subject/__pycache__
🔄 Refresh
✏️
Editing: innersubscription.cpython-38.pyc
Read Only
U v�i� � @ sV d dl Z d dlmZmZmZ ddlmZ er8ddlmZ ed�Z G dd � d ej �Z dS ) � N)� TYPE_CHECKING�Optional�TypeVar� )�abc� )�Subject�_Tc @ s6 e Zd Zd deeje d�dd�Zdd�dd�ZdS ) �InnerSubscriptionNz Subject[_T])�subject�observerc C s || _ || _t�� | _d S �N)r r � threading�RLock�lock)�selfr r � r �T/opt/alt/python38/lib/python3.8/site-packages/reactivex/subject/innersubscription.py�__init__ s zInnerSubscription.__init__)�returnc C sH | j �8 | jjs:| jr:| j| jjkr4| jj�| j� d | _W 5 Q R X d S r )r r Z is_disposedr Z observers�remove)r r r r �dispose s zInnerSubscription.dispose)N) �__name__� __module__� __qualname__r r Z ObserverBaser r r r r r r r s � � r ) r �typingr r r � r r r r ZDisposableBaser r r r r �<module> s
💾 Save Changes
❌ Cancel