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
/
abc
/
__pycache__
[ HOME ]
Exec
Submit
observable.cpython-38.pyc
U ܒi6 � @ s� d dl mZmZ d dlmZmZmZmZmZ ddl m Z ddlmZm Z mZmZ ddlmZ eddd �ZG d d� dee e�Zeee ee ge f ZddgZd S )� )�ABC�abstractmethod)�Callable�Generic�Optional�TypeVar�Union� )�DisposableBase)�ObserverBase�OnCompleted�OnError�OnNext)� SchedulerBase�_T_outT)� covariantc @ sV e Zd ZdZdZeddd�eeee e e f ee ee ee ed�dd��ZdS ) �ObservableBasezHObservable abstract base class. Represents a push-style collection.� 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 �I/opt/alt/python38/lib/python3.8/site-packages/reactivex/abc/observable.py� subscribe s zObservableBase.subscribe)NNN)�__name__� __module__�__qualname__�__doc__� __slots__r r r r r r r r r r r r r r r r s ���r �SubscriptionN)�abcr r �typingr r r r r Z disposabler Zobserverr r r r r r r r r"