U
vi~ @ s d dl mZmZ d dlmZmZmZ edZedddZeegdf Z ee
gdf Z eg df Z G dd d ee eZ
d d
d d gZdS )
)ABCabstractmethod)CallableGenericTypeVar_T_T_inT)
contravariantNc @ sN e Zd ZdZdZeeddddZeedddd Z edd
d d Z
dS )
ObserverBasez|Observer abstract base class
An Observer is the entity that receives all emissions of a
subscribed Observable.
N)valuereturnc C s t dS )zxNotifies the observer of a new element in the sequence.
Args:
value: The received element.
NNotImplementedError)selfr r r G/opt/alt/python38/lib/python3.8/site-packages/reactivex/abc/observer.pyon_next s zObserverBase.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 on_error s zObserverBase.on_error)r
c C s t dS )z1Notifies the observer of the end of the sequence.Nr )r r r r on_completed) s zObserverBase.on_completed) __name__
__module__ __qualname____doc__ __slots__r r r Exceptionr r r r r r r
s r
OnNextOnError OnCompleted)abcr r typingr r r r r r r r r r
__all__r r r r s $