🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 07:14:54 | 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: autodetachobserver.cpython-38.pyc
Read Only
U v�i� � @ sb d dl mZmZ d dlmZ d dlmZmZ ddlm Z m Z eddd�Z G d d � d e j e �Z d S ) � )�Optional�TypeVar)�SingleAssignmentDisposable)� default_error�noop� )�abc�typing�_T_inT)� contravariantc @ s� e Zd Zdeeje eej eej dd�dd�Z edd�dd�Z e dd�d d �Z dd �d d �Z ejdd�dd�Zeed�Zdd �dd�Ze ed�dd�ZdS )�AutoDetachObserverN)�on_next�on_error� on_completed�returnc C s0 |pt | _|pt| _|pt | _t� | _d| _d S )NF)r �_on_nextr � _on_error� _on_completedr � _subscription� is_stopped)�selfr r r � r �V/opt/alt/python38/lib/python3.8/site-packages/reactivex/observer/autodetachobserver.py�__init__ s zAutoDetachObserver.__init__)�valuer c C s | j r d S | �|� d S �N)r r �r r r r r r s zAutoDetachObserver.on_next)�errorr c C s. | j r d S d| _ z| �|� W 5 | �� X d S �NT)r �disposer )r r r r r r s zAutoDetachObserver.on_error)r c C s, | j r d S d| _ z | �� W 5 | �� X d S r )r r r �r r r r r ( s z AutoDetachObserver.on_completedc C s || j _d S r )r Z disposabler r r r �set_disposable2 s z!AutoDetachObserver.set_disposable)�fsetc C s d| _ | j�� d S r )r r r r r r r r 7 s zAutoDetachObserver.dispose)�exnr c C s | j r dS d| _ | �|� dS )NFT)r r )r r# r r r �fail; s zAutoDetachObserver.fail)NNN)�__name__� __module__� __qualname__r r ZOnNextr ZOnErrorZ OnCompletedr r � Exceptionr r r ZDisposableBaser! �propertyZ subscriptionr �boolr$ r r r r r s � � r N) r r r Zreactivex.disposabler Zreactivex.internalr r � r r Z ObserverBaser r r r r �<module> s
💾 Save Changes
❌ Cancel