🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 19:21:30 | 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: asyncsubject.cpython-38.pyc
Read Only
U v�i � @ sd d dl mZmZmZ ddlmZ ddlmZ ddlm Z ddl m Z ed�Z G d d � d e e �Z d S ) � )�Optional�TypeVar�cast� )�abc)� Disposable� )�InnerSubscription)�Subject�_Tc sx e Zd ZdZdd�� fdd� Zdeje eej ej d�dd�Z edd �d d �Z dd�d d �Z dd�� fdd� Z� ZS )� AsyncSubjectz�Represents the result of an asynchronous operation. The last value before the close notification, or the error received through on_error, is sent to all subscribed observers.N)�returnc s t � �� ttd�| _d| _dS )zoCreates a subject that can only receive one value and that value is cached for all future observations.NF)�super�__init__r r �value� has_value��self�� __class__� �O/opt/alt/python38/lib/python3.8/site-packages/reactivex/subject/asyncsubject.pyr s zAsyncSubject.__init__)�observer� schedulerr c C s� | j �H | �� | js8| j�|� t| |�W 5 Q R � S | j}| j}| j}W 5 Q R X |rd|� |� n |r||� |� |� � n|� � t � S )N) �lockZcheck_disposedZ is_stopped� observers�appendr � exceptionr r Zon_error�on_next� on_completedr )r r r �exr r r r r �_subscribe_core s z AsyncSubject._subscribe_core)r r c C s" | j � || _d| _W 5 Q R X dS )z�Remember the value. Upon completion, the most recently received value will be passed on to all subscribed observers. Args: value: The value to remember until completion TN)r r r )r r r r r � _on_next_core2 s zAsyncSubject._on_next_corec C sj | j �& | j�� }| j�� | j}| j}W 5 Q R X |rT|D ]}|�|� |�� q:n|D ] }|�� qXdS )z�Notifies all subscribed observers of the end of the sequence. The most recently received value, if any, will now be passed on to all subscribed observers.N)r r �copy�clearr r r r )r r r r r r r r �_on_completed_core= s z AsyncSubject._on_completed_corec s, | j � ttd�| _t� �� W 5 Q R X dS )z0Unsubscribe all observers and release resources.N)r r r r r �disposer r r r r& P s zAsyncSubject.dispose)N)�__name__� __module__� __qualname__�__doc__r r Z ObserverBaser r Z SchedulerBaseZDisposableBaser! r" r% r& � __classcell__r r r r r s �� r N)�typingr r r � r Z disposabler Zinnersubscriptionr �subjectr r r r r r r �<module> s
💾 Save Changes
❌ Cancel