🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 07:00:45 | PHP 8.2.32
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/__pycache__
🔄 Refresh
✏️
Editing: notification.cpython-38.pyc
Read Only
U v�i� � @ s� d dl mZ d dlmZmZmZmZmZmZ d dl m Z mZ d dl m Z ddl m Z ddlmZ ed�ZG d d � d ee �ZG d d � d ee �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 e ej e ej dd�dd�Zeeje e ej e ej dd�d d ��Zee j e dd �d d ��Zde e 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" 2 s zNotification._accept��observerr c C s t �d S r% r& �r r) r r r r! ; s z Notification._accept_observer)� schedulerr c s< |p t �� � dtjt ttj tjd�� �fdd� }t|�S )a} Returns an observable sequence with a single notification, using the specified scheduler, else the immediate scheduler. Args: scheduler: [Optional] Scheduler to send out the notification calls on. Returns: An observable sequence that surfaces the behavior of the notification upon subscription. N)r) r+ r c s, t jtd d�� �fdd� }|p �}|�|�S )N)r+ �stater c s �� � � �jdkr � �� d S )N�N)r! r r )r+ r, )r) r r r �actionT s z=Notification.to_observable.<locals>.subscribe.<locals>.action)r � SchedulerBaser Zschedule)r) r+ r. Z_Notification__scheduler�Z _schedulerr )r) r � subscribeP s z-Notification.to_observable.<locals>.subscribe)N) r Z singletonr r r r r/ ZDisposableBaser )r r+ r1 r r0 r � to_observable? s �� zNotification.to_observablezNotification[_T])�otherr c C s |sdnt |�}t | �|kS )zIIndicates whether this instance and a specified object are equal.r )�str)r r3 Z other_stringr r r �equals^ s zNotification.equalsc C s | � |�S r% )r5 )r r3 r r r �__eq__e s zNotification.__eq__)NN)N)�__name__� __module__� __qualname__�__doc__r r r �OnNextr r r r �OnError� OnCompletedr$ r r" r! r/ ZObservableBaser2 �boolr5 r r6 r r r r r s2 �� � �� r c st e Zd ZdZedd�� fdd� Zdeje eej eej dd�dd�Z e j e dd �d d �Zed �d d�Z� ZS )r; z1Represents an OnNext notification to an observer.N��valuer c s$ t t| ��� || _d| _d| _dS )z)Constructs a notification of a new value.Tr- N)�superr; r r@ r r )r r@ �� __class__r r r l s zOnNext.__init__r c C s || j �S r% �r@ r# r r r r" t s zOnNext._acceptr( c C s |� | j�S r% )r r@ r* r r r r! | s zOnNext._accept_observerr c C s$ | j }t|t�rt|�}dt|� S )Nz OnNext(%s))r@ r �int�floatr4 )r �valr r r �__str__ s zOnNext.__str__)NN)r7 r8 r9 r: r r r r; r r< r= r" r r r! r4 rH � __classcell__r r rB r r; i s �� r; c sz e Zd ZdZeeef dd�� fdd� Zej e e ej e ej dd�dd�Zeje dd �d d �Zed �d d�Z� ZS )r< z2Represents an OnError notification to an observer.N��errorr c s0 t t| ��� t|t�r |nt|�| _d| _dS )z*Constructs a notification of an exception.�EN)rA r< r r � Exception� exceptionr )r rK rB r r r � s �zOnError.__init__r c C s |r|| j �S d S r% )rN r# r r r r" � s zOnError._acceptr( c C s |� | j�S r% )r rN r* r r r r! � s zOnError._accept_observerr c C s dt | j� S )Nz OnError(%s))r4 rN r r r r rH � s zOnError.__str__)r7 r8 r9 r: r rM r4 r r r; r r r< r= r" r r r! rH rI r r rB r r< � s � r< c sp e Zd ZdZdd�� fdd� Zeje eej eej dd�dd�Z e j e dd �d d �Zed�d d �Z� ZS )r= z6Represents an OnCompleted notification to an observer.Nr c s t t| ��� d| _dS )z3Constructs a notification of the end of a sequence.�CN)rA r= r r r rB r r r � s zOnCompleted.__init__r c C s |r |� S d S r% r r# r r r r" � s zOnCompleted._acceptr( c C s |� � S r% )r r* r r r r! � s z OnCompleted._accept_observerc C s dS )Nz OnCompleted()r r r r r rH � s zOnCompleted.__str__)r7 r8 r9 r: r r r; r r r< r= r" r r r! r4 rH rI r r rB r r= � s � r= N)�handlerr c sF t dd�� fdd� }tdd�� fdd� }dd�� fd d � }t|||�S ) a Creates an observer from a notification callback. Args: handler: Action that handles a notification. Returns: The observer object that invokes the specified handler using a notification corresponding to each message it receives. Nr? c s � t | ��S r% )r; rD �rP r r �_on_next� s z from_notifier.<locals>._on_nextrJ c s � t | ��S r% )r< )rK rQ r r � _on_error� s z from_notifier.<locals>._on_errorr c s � t � �S r% )r= r rQ r r � _on_completed� s z$from_notifier.<locals>._on_completed)r rM r )rP rR rS rT r rQ r � from_notifier� s rU )r r r r r r r r r Z reactivexZreactivex.schedulerr Z observabler r) r r r r; r< r= rU r r r r �<module> s \
💾 Save Changes
❌ Cancel