🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 16:39:06 | PHP 8.2.32
📂
/ (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: subject.cpython-38.pyc
Read Only
U v�iL � @ s� d dl Z d dlmZmZmZ ddlmZ ddlmZ ddl m Z ddl m Z ddl mZ d d lmZ ed �ZG d d � d e e ee eje �ZdS )� N)�List�Optional�TypeVar� )�abc)� Disposable)�DisposedException)� Observable)�Observer� )�InnerSubscription�_Tc s� e Zd ZdZdd�� fdd� Zdd�dd�Zdeje e ej ej d�d d �Z edd �� fd d � Z edd �dd�Zedd�� fdd� Zedd�dd�Zdd�� fdd� Zdd�dd�Zdd�� fdd� Z� ZS ) �Subjectz�Represents an object that is both an observable sequence as well as an observer. Each notification is broadcasted to all subscribed observers. N)�returnc s* t � �� d| _g | _d | _t�� | _d S )NF)�super�__init__� is_disposed� observers� exception� threading�RLock�lock��self�� __class__� �J/opt/alt/python38/lib/python3.8/site-packages/reactivex/subject/subject.pyr s zSubject.__init__c C s | j r t� �d S �N)r r r r r r �check_disposed s zSubject.check_disposed)�observer� schedulerr c C st | j �d | �� | js8| j�|� t| |�W 5 Q R � S | jd k rP|�| j� n|�� t � W 5 Q R � S Q R X d S r ) r r Z is_stoppedr �appendr r �on_error� on_completedr )r r r! r r r �_subscribe_core! s zSubject._subscribe_core)�valuer c s* | j � | �� W 5 Q R X t� �|� dS )z�Notifies all subscribed observers with the value. Args: value: The value to send to all subscribed observers. N)r r r �on_next)r r& r r r r' 2 s zSubject.on_nextc C s4 | j � | j�� }W 5 Q R X |D ]}|�|� q d S r )r r �copyr' )r r& r r r r r � _on_next_core= s zSubject._on_next_core)�errorr c s* | j � | �� W 5 Q R X t� �|� dS )z�Notifies all subscribed observers with the exception. Args: error: The exception to send to all subscribed observers. N)r r r r# )r r* r r r r# D s zSubject.on_errorc C sD | j � | j�� }| j�� || _W 5 Q R X |D ]}|�|� q0d S r )r r r( �clearr r# )r r* r r r r r �_on_error_coreO s zSubject._on_error_corec s( | j � | �� W 5 Q R X t� �� dS )z=Notifies all subscribed observers of the end of the sequence.N)r r r r$ r r r r r$ X s zSubject.on_completedc C s< | j � | j�� }| j�� W 5 Q R X |D ] }|�� q*d S r )r r r( r+ r$ )r r r r r r �_on_completed_core_ s zSubject._on_completed_corec s2 | j �" d| _g | _d| _t� �� W 5 Q R X dS )z0Unsubscribe all observers and release resources.TN)r r r r r �disposer r r r r. g s zSubject.dispose)N)�__name__� __module__� __qualname__�__doc__r r r Z ObserverBaser r Z SchedulerBaseZDisposableBaser% r' r) � Exceptionr# r, r$ r- r. � __classcell__r r r r r s �� r )r �typingr r r � r Z disposabler Zinternalr Z observabler r r Zinnersubscriptionr r Z SubjectBaser r r r r �<module> s
💾 Save Changes
❌ Cancel