U
vi
@ s d dl mZ d dlmZmZmZmZ d dlmZ d dl m
Z
m Z d dl m
Z
mZmZ edddZerrd d lmZ nG d
d d ZG d d
d
eje ejZdS ) ) annotations)
TYPE_CHECKINGCallableOptionalTypeVar)abc)
default_errornoop) OnCompletedOnErrorOnNext_T_inT)
contravariant) Notificationc @ s e Zd ZdS )r N)__name__
__module__ __qualname__ r r L/opt/alt/python38/lib/python3.8/site-packages/reactivex/observer/observer.pyr s r c @ s e Zd ZdZd)ddddddd Zd
dd d d
Zd
dd ddZdddddZdddddZddddZ ddddZ
dddd Z dd d d d Z dddd!d"Z
d#dd$d%Zd&dd'd(ZdS )*ObserverzBase class for implementations of the Observer class. This base
class enforces the grammar of observers where OnError and
OnCompleted are terminal messages.
NzOptional[OnNext[_T_in]]zOptional[OnError]zOptional[OnCompleted]None)on_nexton_error on_completedreturnc C s( d| _ |p t| _|pt| _|p t| _d S )NF)
is_stoppedr _handler_on_nextr _handler_on_error_handler_on_completed)selfr r r r r r __init__ s
zObserver.__init__r
)valuer c C s | j s| | dS )z5Notify the observer of a new element in the sequence.N)r
_on_next_corer r! r r r r $ s zObserver.on_nextc C s | | dS )ztFor Subclassing purpose. This method is called by `on_next()`
method until the observer is stopped.
N)r r# r r r r" ) s zObserver._on_next_core Exception)errorr c C s | j sd| _ | | dS )zwNotify the observer that an exception has occurred.
Args:
error: The error that occurred.
TNr _on_error_corer r% r r r r / s zObserver.on_errorc C s | | dS )zuFor Subclassing purpose. This method is called by `on_error()`
method until the observer is stopped.
N)r r( r r r r' : s zObserver._on_error_core)r c C s | j sd| _ | dS )z1Notifies the observer of the end of the sequence.TN)r _on_completed_corer r r r r @ s zObserver.on_completedc C s | dS )zyFor Subclassing purpose. This method is called by `on_completed()`
method until the observer is stopped.
N)r r* r r r r) G s zObserver._on_completed_corec C s
d| _ dS )zMDisposes the observer, causing it to transition to the
stopped state.TN)r r* r r r disposeM s zObserver.disposebool)exnr c C s | j sd| _ | | dS dS )NTFr& )r r- r r r failR s
z
Observer.failc C s dd l }| |d S )Nr ) traceback print_stack)r r% r/ r r r throwZ s zObserver.throwz%Callable[[Notification[_T_in]], None]c s ddd fdd }|S )zCreates a notification callback from an observer.
Returns the action that forwards its input notification to the
underlying observer.zNotification[_T_in]r )notifierr c s
| S )N)accept)r2 r* r r funcf s z"Observer.to_notifier..funcr )r r4 r r* r to_notifier` s zObserver.to_notifierzabc.ObserverBase[_T_in]c C s t | j| j| jS )zHides the identity of an observer.
Returns an observer that hides the identity of the specified
observer.
)r r r r r* r r r as_observerk s zObserver.as_observer)NNN)r r r __doc__r r r" r r' r r) r+ r. r1 r5 r6 r r r r r s r N)
__future__r typingr r r r Z reactivexr Zreactivex.internal.basicr r Zreactivex.typingr
r r r
Zreactivex.notificationr Z ObserverBaseZDisposableBaser r r r r s