U
vi @ s d dl mZ d dlmZmZmZmZmZmZ d dl m Z mZ d dl
m Z ddl m
Z
ddlmZ edZG d d
d
ee ZG d d d ee ZG d
d dee ZG dd dee Zeee gdf ee dddZdS ) )abstractmethod)AnyCallableGenericOptionalTypeVarUnion)abctyping)ImmediateScheduler )
Observable)Observer_Tc @ s e Zd ZdZddddZdeeje e j
e f e ej e ej
ddddZeeje e ej e ej
ddd d
Zee j
e dd d d
Zde e j e je dddZdedddZeedddZdS ) Notificationz)Represents a notification to an observer.Nreturnc C s d| _ | d| _dS )z*Default constructor used by derived types.F N) has_valuekindself r G/opt/alt/python38/lib/python3.8/site-packages/reactivex/notification.py__init__ s zNotification.__init__on_nexton_error on_completedr c C s$ t |tjr| |S | |||S )aS Invokes the delegate corresponding to the notification or an
observer and returns the produced result.
Examples:
>>> notification.accept(observer)
>>> notification.accept(on_next, on_error, on_completed)
Args:
on_next: Delegate to invoke for an OnNext notification.
on_error: [Optional] Delegate to invoke for an OnError
notification.
on_completed: [Optional] Delegate to invoke for an
OnCompleted notification.
Returns:
Result produced by the observation.)
isinstancer ObserverBase_accept_observer_acceptr r r r r r r accept s
zNotification.acceptc C s t d S NNotImplementedErrorr# r r r r" 2 s zNotification._acceptobserverr c C s t d S r% r& r r) r r r r! ; s z Notification._accept_observer) schedulerr c s< |p
t dtjt ttj tjd fdd
}t|S )a} Returns an observable sequence with a single notification,
using the specified scheduler, else the immediate scheduler.
Args:
scheduler: [Optional] Scheduler to send out the
notification calls on.
Returns:
An observable sequence that surfaces the behavior of the
notification upon subscription.
N)r) r+ r c s, t jtd d fdd }|p }||S )N)r+ stater c s jdkr d S )NN)r! r r )r+ r, )r) r r r actionT s
z=Notification.to_observable..subscribe..action)r
SchedulerBaser Zschedule)r) r+ r. Z_Notification__schedulerZ
_schedulerr )r) r subscribeP s z-Notification.to_observable..subscribe)N) r Z singletonr r r r r/ ZDisposableBaser
)r r+ r1 r r0 r
to_observable? s zNotification.to_observablezNotification[_T])otherr c C s |sdnt |}t | |kS )zIIndicates whether this instance and a specified object are
equal.r )str)r r3 Z other_stringr r r equals^ s zNotification.equalsc C s
| |S r% )r5 )r r3 r r r __eq__e s zNotification.__eq__)NN)N)__name__
__module__ __qualname____doc__r r r
OnNextr r r r OnError OnCompletedr$ r r" r! r/ ZObservableBaser2 boolr5 r r6 r r r r r
s2 r c st e Zd ZdZedd fdd Zdeje eej eej
ddddZ e j
e dd d
d Zed d
dZ ZS )r; z1Represents an OnNext notification to an observer.Nvaluer c s$ t t| || _d| _d| _dS )z)Constructs a notification of a new value.Tr- N)superr; r r@ r r )r r@ __class__r r r l s zOnNext.__init__r c C s
|| j S r% r@ r# r r r r" t s zOnNext._acceptr( c C s | | jS r% )r r@ r* r r r r! | s zOnNext._accept_observerr c C s$ | j }t|trt|}dt| S )Nz
OnNext(%s))r@ r intfloatr4 )r valr r r __str__ s
zOnNext.__str__)NN)r7 r8 r9 r: r r r
r; r r< r= r" r r r! r4 rH
__classcell__r r rB r r; i s r; c sz e Zd ZdZeeef dd fdd Zej e
e ej e ej
ddddZeje
dd d
d Zed d
dZ ZS )r< z2Represents an OnError notification to an observer.Nerrorr c s0 t t| t|tr |nt|| _d| _dS )z*Constructs a notification of an exception.EN)rA r< r r Exception exceptionr )r rK rB r r r s zOnError.__init__r c C s |r|| j S d S r% )rN r# r r r r" s zOnError._acceptr( c C s | | jS r% )r rN r* r r r r! s zOnError._accept_observerr c C s dt | j S )Nz OnError(%s))r4 rN r r r r rH s zOnError.__str__)r7 r8 r9 r: r rM r4 r r
r; r r r< r= r" r r r! rH rI r r rB r r< s r< c sp e Zd ZdZdd fdd Zeje eej eej
ddddZ e j
e dd d
d Zedd d
Z ZS )r= z6Represents an OnCompleted notification to an observer.Nr c s t t| d| _dS )z3Constructs a notification of the end of a sequence.CN)rA r= r r r rB r r r s zOnCompleted.__init__r c C s |r
| S d S r% r r# r r r r" s zOnCompleted._acceptr( c C s | S r% )r r* r r r r! s z OnCompleted._accept_observerc C s dS )Nz
OnCompleted()r r r r r rH s zOnCompleted.__str__)r7 r8 r9 r: r r
r; r r r< r= r" r r r! r4 rH rI r r rB r r= s r= N)handlerr c sF t dd fdd }tdd fdd }dd fd d
}t|||S ) a Creates an observer from a notification callback.
Args:
handler: Action that handles a notification.
Returns:
The observer object that invokes the specified handler using
a notification corresponding to each message it receives.
Nr? c s t | S r% )r; rD rP r r _on_next s z from_notifier.._on_nextrJ c s t | S r% )r< )rK rQ r r _on_error s z from_notifier.._on_errorr c s
t S r% )r= r rQ r r
_on_completed s z$from_notifier.._on_completed)r rM r )rP rR rS rT r rQ r
from_notifier s rU )r r r
r r r r r r Z reactivexZreactivex.schedulerr Z
observabler
r) r r r r; r< r= rU r r r r s \