U
vis @ s d dl mZ d dlmZmZmZ ddlmZ ddlm Z ddl
m Z m Z m
Z
mZ ddlmZ edZG d d
d
e e e e Zd
gZd S ) )abstractmethod)OptionalTypeVarUnion )DisposableBase)ObservableBase) ObserverBase OnCompletedOnErrorOnNext)
SchedulerBase_Tc @ s e Zd ZdZdZedddeeee e
e f ee ee ee
edddZee ddd d
Zeedd d d
ZeddddZdS ) SubjectBasez{Subject abstract base class.
Represents an object that is both an observable sequence as well
as an observer.
N) scheduler)on_nexton_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.
NNotImplementedError)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 s <