U
vi+* @ s^ d dl mZmZmZmZmZ d dlmZmZm Z d dl m
Z
edZ d ee j e ee j
ee j eee gee f dddZeje eee gee f d d
d Zee e j e ee d d
dZee e jdddZee e jdddZee e jdddZee e jdddZe jeee gee f dd d Zd ddd ddddgZdS ) )AnyCallableListOptionalTypeVar)
Observableabctyping)CompositeDisposable_TN)on_nexton_error on_completedreturnc s$ t t t t d fdd }|S )Nsourcer c s4 dt jt tt j t jd fdd
}t|S )a Invokes an action for each element in the observable
sequence and invokes an action on graceful or exceptional
termination of the observable sequence. This method can be used
for debugging, logging, etc. of query behavior by intercepting
the message stream to run arbitrary actions for messages on the
pipeline.
Examples:
>>> do_action(send)(observable)
>>> do_action(on_next, on_error)(observable)
>>> do_action(on_next, on_error, on_completed)(observable)
Args:
on_next: [Optional] Action to invoke for each element in
the observable sequence.
on_error: [Optional] Action to invoke on exceptional
termination of the observable sequence.
on_completed: [Optional] Action to invoke on graceful
termination of the observable sequence.
Returns:
An observable source sequence with the side-effecting
behavior applied.
Nobserver schedulerr c sR t d d fdd }td d fdd }d d fdd }j||||d
S ) N)xr c
sX s | nDz | W n, tk
rH } z | W 5 d }~X Y nX | d S Nr Exceptionr
)r e)r r H/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_do.py_on_next, s zBdo_action_..do_action..subscribe.._on_next exceptionr c
sX s | nDz | W n, tk
rH } z | W 5 d }~X Y nX | d S r r
r )r r )r r
r r _on_error7 s zCdo_action_..do_action..subscribe.._on_errorr c
sR s n@z
W n, tk
rD } z | W 5 d } ~ X Y nX d S r r r r
)r )r r r r
_on_completedB s
zGdo_action_..do_action..subscribe.._on_completedr )r r subscribe)r r r r r# )r r
r r r r r% ( s z0do_action_..do_action..subscribe)Nr ObserverBaser r
SchedulerBaseDisposableBaser r r% r r
r r r do_action s )z do_action_..do_action)r r )r r
r r. r r, r
do_action_ s Er/ )r r c C s t | j| j| jS )a. Invokes an action for each element in the observable sequence and
invokes an action on graceful or exceptional termination of the
observable sequence. This method can be used for debugging, logging,
etc. of query behavior by intercepting the message stream to run
arbitrary actions for messages on the pipeline.
>>> do(observer)
Args:
observer: Observer
Returns:
An operator function that takes the source observable and
returns the source sequence with the side-effecting behavior
applied.
)r/ r r
r r& r r r do_V s r0 )r
after_nextr c s0 dt jt tt j t jd fdd
}t|S )zInvokes an action with each element after it has been emitted downstream.
This can be helpful for debugging, logging, and other side effects.
after_next -- Action to invoke on each element after it has been emitted
Nr c s& t d fdd }| j jS )N)valuec
sH z | | W n, tk
rB } z| W 5 d }~X Y nX d S r r )r2 r )r1 r r r r w s
z1do_after_next..subscribe..on_next)r r% r
r )r r r r1 r r& r r% t s z do_after_next..subscribe)Nr' )r r1 r% r r3 r
do_after_nextk s
r4 )r on_subscribec s0 dt jt tt j t jd fdd
}t|S )zInvokes an action on subscription.
This can be helpful for debugging, logging, and other side effects
on the start of an operation.
Args:
on_subscribe: Action to invoke on subscription
Nr c s j | j| j| j|dS Nr$ )r% r r
r )r r r5 r r r r% s z"do_on_subscribe..subscribe)Nr r( r r r) r* r )r r5 r% r r7 r do_on_subscribe s r9 )r
on_disposec sF G fdddt j dt jt tt j t jd fdd
}t|S )zInvokes an action on disposal.
This can be helpful for debugging, logging, and other side effects
on the disposal of an operation.
Args:
on_dispose: Action to invoke on disposal
c s e Zd Zdd fdd ZdS )z do_on_dispose..OnDisposeNr! c s
d S r r selfr: r r dispose s z(do_on_dispose..OnDispose.dispose)__name__
__module__ __qualname__r> r r= r r OnDispose s rB Nr c s8 t }| j| j| j| j|d}|| |S r6 )r
addr% r r
r )r r composite_disposable subscription)rB r r r r% s
z do_on_dispose..subscribe)N)r r* r( r r r) r )r r: r% r )rB r: r r
do_on_dispose s
rF )r on_terminatec s0 dt jt tt j t jd fdd
}t|S )a Invokes an action on an on_complete() or on_error() event.
This can be helpful for debugging, logging, and other side effects
when completion or an error terminates an operation.
on_terminate -- Action to invoke when on_complete or throw is called
Nr c s6 fdd}t d fdd }j j|||dS )Nc
sD z
W n, t k
r6 } z | W 5 d } ~ X Y n
X d S r )r r
r errr rG r r r s
z8do_on_terminate..subscribe..on_completedr c
sF z
W n, t k
r6 } z | W 5 d }~X Y n X | d S r )r r
r rI rJ r r r
s
z4do_on_terminate..subscribe..on_errorr$ r r% r r r r r
rG r r& r r% s z"do_on_terminate..subscribe)Nr8 )r rG r% r rO r do_on_terminate s
rP )r after_terminatec s0 dt jt tt j t jd fdd
}t|S )a Invokes an action after an on_complete() or on_error() event.
This can be helpful for debugging, logging, and other side effects
when completion or an error terminates an operation
on_terminate -- Action to invoke after on_complete or throw is called
Nr c s8 fdd}t d d fdd }j j|||dS )Nc
sD z
W n, tk
r> } z| W 5 d } ~ X Y nX d S r r" rH rQ r r r r s
z;do_after_terminate..subscribe..on_completedr c
sF | z
W n, tk
r@ } z | W 5 d }~X Y nX d S r r rL rR r r r
s
z7do_after_terminate..subscribe..on_errorr$ rM rN rQ r r& r r% s z%do_after_terminate..subscribe)Nr8 )r rQ r% r rS r do_after_terminate s
rT )finally_actionr c s8 G fdddt j tt tt d fdd }|S )a Invokes an action after an on_complete(), on_error(), or disposal
event occurs.
This can be helpful for debugging, logging, and other side effects
when completion, an error, or disposal terminates an operation.
Note this operator will strive to execute the finally_action once,
and prevent any redudant calls
Args:
finally_action -- Action to invoke after on_complete, on_error,
or disposal is called
c s0 e Zd Zee dddZdd fdd ZdS )z do_finally..OnDispose was_invokedc S s
|| _ d S r rV )r< rW r r r __init__ s z&do_finally..OnDispose.__init__Nr! c s | j d s d| j d< d S Nr TrV r; rU r r r> s
z%do_finally..OnDispose.dispose)r? r@ rA r boolrX r> r rZ r r rB s rB r c s2 dt jt tt j t jd fdd
}t|S )Nr c sb dg fdd}t d fdd }t }| j j|||d}|| |S )NFc
sT zd s dd< W n, tk
rN } z| W 5 d } ~ X Y nX d S rY r" rH rU r rW r r r s zDdo_finally..partial..subscribe..on_completedrK c
sV | zd s" dd< W n, tk
rP } z | W 5 d }~X Y nX d S rY r rL r\ r r r
( s
z@do_finally..partial..subscribe..on_errorr$ )r r
rC r% r )r r r r
rD rE )rB rU r )r rW r r% s
z.do_finally..partial..subscribe)Nr' r+ rB rU r- r partial s !zdo_finally..partial)r r* r r )rU r^ r r] r
do_finally s $r_ )NNN)r r r r r r Z reactivexr r Zreactivex.disposabler
r ZOnNextZOnErrorZ OnCompletedr/ r( r0 r4 Actionr9 rF rP rT r_ __all__r r r r sB M( #" B