🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 04:48:50 | 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: subject.cpython-38.pyc
Read Only
U v�is � @ s� d dl mZ d dlmZmZmZ ddlmZ ddlm Z ddl m Z m Z m Z mZ ddlmZ ed�ZG d d � d e e e e �Zd gZd S ) � )�abstractmethod)�Optional�TypeVar�Union� )�DisposableBase)�ObservableBase)� ObserverBase� OnCompleted�OnError�OnNext)� SchedulerBase�_Tc @ s� e Zd ZdZdZeddd�eeee e e f ee ee ee ed�dd��Zee dd�d d ��Zeedd �d d ��Zedd�dd��ZdS )� SubjectBasez{Subject abstract base class. Represents an object that is both an observable sequence as well as an observer. � N)� scheduler)�on_next�on_error� on_completedr �returnc C s t �dS )a� Subscribe an observer to the observable sequence. Args: observer: [Optional] The object that is to receive notifications. scheduler: [Optional] The default scheduler to use for this subscription. Returns: Disposable object representing an observer's subscription to the observable sequence. N��NotImplementedError)�selfr r r r r r �F/opt/alt/python38/lib/python3.8/site-packages/reactivex/abc/subject.py� subscribe s zSubjectBase.subscribe)�valuer c C s t �dS )zxNotifies the observer of a new element in the sequence. Args: value: The received element. Nr )r r r r r r - s zSubjectBase.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 r 7 s zSubjectBase.on_error)r c C s t �dS )z1Notifies the observer of the end of the sequence.Nr )r r r r r A s zSubjectBase.on_completed)NNN)�__name__� __module__� __qualname__�__doc__� __slots__r r r r r r r r r r r r � Exceptionr r r r r r r s* ��� r N)�abcr �typingr r r Z disposabler Z observabler Zobserverr r r r r r r r �__all__r r r r �<module> s <
💾 Save Changes
❌ Cancel