🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 03:33:31 | PHP 8.2.32
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
abc
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/abc/__pycache__
🔄 Refresh
✏️
Editing: observer.cpython-38.pyc
Read Only
U v�i~ � @ s� d dl mZmZ d dlmZmZmZ ed�Zeddd�Zeegdf Z ee gdf Z eg df Z G dd � d ee e�Z d d d d gZdS ) � )�ABC�abstractmethod)�Callable�Generic�TypeVar�_T�_T_inT)� contravariantNc @ sN e Zd ZdZdZeedd�dd��Zeedd�dd ��Z edd �d d ��Z dS ) � ObserverBasez|Observer abstract base class An Observer is the entity that receives all emissions of a subscribed Observable. � N)�value�returnc C s t �dS )zxNotifies the observer of a new element in the sequence. Args: value: The received element. N��NotImplementedError)�selfr r r �G/opt/alt/python38/lib/python3.8/site-packages/reactivex/abc/observer.py�on_next s zObserverBase.on_next)�errorr c C s t �dS )z}Notifies the observer that an exception has occurred. Args: error: The error that has occurred. Nr )r r r r r �on_error s zObserverBase.on_error)r c C s t �dS )z1Notifies the observer of the end of the sequence.Nr )r r r r � on_completed) s zObserverBase.on_completed) �__name__� __module__� __qualname__�__doc__� __slots__r r r � Exceptionr r r r r r r s r �OnNext�OnError� OnCompleted)�abcr r �typingr r r r r r r r r r �__all__r r r r �<module> s $
💾 Save Changes
❌ Cancel