🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 07:01:50 | 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: observer.cpython-38.pyc
Read Only
U v�i� � @ s� d dl mZ d dlmZmZmZmZ d dlmZ d dl m Z m Z d dl m Z mZmZ eddd�Zerrd d lmZ nG d d � d �ZG d d � d eje ej�ZdS )� )� annotations)� TYPE_CHECKING�Callable�Optional�TypeVar)�abc)� default_error�noop)� OnCompleted�OnError�OnNext�_T_inT)� contravariant)� Notificationc @ s e Zd ZdS )r N)�__name__� __module__� __qualname__� r r �L/opt/alt/python38/lib/python3.8/site-packages/reactivex/observer/observer.pyr s r c @ s� e Zd ZdZd)ddddd�dd �Zd dd �d d �Zd dd �dd�Zddd�dd�Zddd�dd�Zdd�dd�Z dd�dd�Z dd�dd �Z dd d �d d �Z ddd�d!d"�Z d#d�d$d%�Zd&d�d'd(�ZdS )*�Observerz�Base class for implementations of the Observer class. This base class enforces the grammar of observers where OnError and OnCompleted are terminal messages. NzOptional[OnNext[_T_in]]zOptional[OnError]zOptional[OnCompleted]�None)�on_next�on_error� on_completed�returnc C s( d| _ |p t| _|pt| _|p t| _d S )NF)� is_stoppedr �_handler_on_nextr �_handler_on_error�_handler_on_completed)�selfr r r r r r �__init__ s zObserver.__init__r )�valuer c C s | j s| �|� dS )z5Notify the observer of a new element in the sequence.N)r � _on_next_core�r r! r r r r $ s zObserver.on_nextc C s | � |� dS )ztFor Subclassing purpose. This method is called by `on_next()` method until the observer is stopped. N)r r# r r r r" ) s zObserver._on_next_core� Exception)�errorr c C s | j sd| _ | �|� dS )zwNotify the observer that an exception has occurred. Args: error: The error that occurred. TN�r �_on_error_core�r r% r r r r / s zObserver.on_errorc C s | � |� dS )zuFor Subclassing purpose. This method is called by `on_error()` method until the observer is stopped. N)r r( r r r r' : s zObserver._on_error_core)r c C s | j sd| _ | �� dS )z1Notifies the observer of the end of the sequence.TN)r �_on_completed_core�r r r r r @ s zObserver.on_completedc C s | � � dS )zyFor Subclassing purpose. This method is called by `on_completed()` method until the observer is stopped. N)r r* r r r r) G s zObserver._on_completed_corec C s d| _ dS )zMDisposes the observer, causing it to transition to the stopped state.TN)r r* r r r �disposeM s zObserver.dispose�bool)�exnr c C s | j sd| _ | �|� dS dS )NTFr& )r r- r r r �failR s z Observer.failc C s dd l }|�� |�d S )Nr )� traceback� print_stack)r r% r/ r r r �throwZ s zObserver.throwz%Callable[[Notification[_T_in]], None]c s ddd�� fdd� }|S )z�Creates a notification callback from an observer. Returns the action that forwards its input notification to the underlying observer.zNotification[_T_in]r )�notifierr c s | � � �S )N)�accept)r2 r* r r �funcf s z"Observer.to_notifier.<locals>.funcr )r r4 r r* r � to_notifier` s zObserver.to_notifierzabc.ObserverBase[_T_in]c C s t | j| j| j�S )z�Hides the identity of an observer. Returns an observer that hides the identity of the specified observer. )r r r r r* r r r � as_observerk s zObserver.as_observer)NNN)r r r �__doc__r r r" r r' r r) r+ r. r1 r5 r6 r r r r r s � r N)� __future__r �typingr r r r Z reactivexr Zreactivex.internal.basicr r Zreactivex.typingr r r r Zreactivex.notificationr Z ObserverBaseZDisposableBaser r r r r �<module> s
💾 Save Changes
❌ Cancel