🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 06:00:09 | PHP 8.2.32
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
observer
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/observer/__pycache__
🔄 Refresh
✏️
Editing: scheduledobserver.cpython-38.pyc
Read Only
U v�i� � @ sh d dl Z d dlmZmZmZ d dlmZmZ d dlmZ ddl m Z eddd �Z G d d � d e e �Z dS ) � N)�Any�List�TypeVar)�abc�typing)�SerialDisposable� )�Observer�_T_inT)� contravariantc s� e Zd Zejeje dd�� fdd� Zedd�dd�Z e dd�d d �Z dd �d d �Z dd �dd�Z ejedd�dd�Zdd �� fdd� Z� ZS )�ScheduledObserverN)� scheduler�observer�returnc s> t � �� || _|| _t�� | _d| _d| _g | _ t � | _ d S )NF) �super�__init__r r � threading�RLock�lock� is_acquired� has_faulted�queuer � disposable)�selfr r �� __class__� �U/opt/alt/python38/lib/python3.8/site-packages/reactivex/observer/scheduledobserver.pyr s zScheduledObserver.__init__)�valuer c s$ d d�� �fdd� }� j �|� d S )N�r c s � j ��� d S �N)r Zon_nextr �r r r r �action s z/ScheduledObserver._on_next_core.<locals>.action�r �append)r r r" r r! r � _on_next_core s z ScheduledObserver._on_next_core)�errorr c s$ d d�� �fdd� }�j �|� d S )Nr c s �j �� � d S r )r Zon_errorr �r& r r r r" % s z0ScheduledObserver._on_error_core.<locals>.actionr# )r r& r" r r' r �_on_error_core$ s z ScheduledObserver._on_error_corer c s" d d�� fdd� }� j �|� d S )Nr c s � j �� d S r )r Z on_completedr �r r r r" + s z4ScheduledObserver._on_completed_core.<locals>.actionr# )r r" r r) r �_on_completed_core* s z$ScheduledObserver._on_completed_corec C sJ d}| j � | js&| jr&| j }d| _W 5 Q R X |rF| j�| j�| j_d S )NFT)r r r r r �schedule�runr )r Zis_ownerr r r � ensure_active0 s z ScheduledObserver.ensure_active)r �stater c C s� | }| j �. |jr |j�d�}nd|_W 5 Q R � d S W 5 Q R X z |� W n4 tk r| | j � g |_d|_W 5 Q R X � Y nX | j�| j� d S )Nr FT) r r �popr � Exceptionr r r+ r, )r r r. �parentZworkr r r r, ; s zScheduledObserver.runc s t � �� | j�� d S r )r �disposer r) r r r r2 O s zScheduledObserver.dispose)�__name__� __module__� __qualname__r Z SchedulerBaseZ ObserverBaser r r r% r0 r( r* r- r, r2 � __classcell__r r r r r s � r ) r r r r r Z reactivexr Zreactivex.disposabler r r r r r r r r �<module> s
💾 Save Changes
❌ Cancel