🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 10:33:18 | PHP 8.2.32
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
operators
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/__pycache__
🔄 Refresh
✏️
Editing: _do.cpython-38.pyc
Read Only
U v�i+* � @ s^ d dl mZmZmZmZmZ d dlmZmZm Z d dl m Z ed�Z d ee j e ee j ee j eee gee f d�dd�Zeje eee gee f d �d d �Zee e j e ee d �d d�Zee e jd�dd�Zee e jd�dd�Zee e jd�dd�Zee e jd�dd�Ze jeee gee f d�d d �Zd ddd ddddgZdS ) � )�Any�Callable�List�Optional�TypeVar)� Observable�abc�typing)�CompositeDisposable�_TN)�on_next�on_error� on_completed�returnc s$ t t t t d�� ��fdd� }|S )N��sourcer 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. N��observer� 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 �N�r � Exceptionr )r �e)r r � �H/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_do.py�_on_next, s zBdo_action_.<locals>.do_action.<locals>.subscribe.<locals>._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_.<locals>.do_action.<locals>.subscribe.<locals>._on_error�r 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_.<locals>.do_action.<locals>.subscribe.<locals>._on_completed�r )r r � subscribe)r r r r r# )r r r r �r r r% ( s �z0do_action_.<locals>.do_action.<locals>.subscribe)N�r � ObserverBaser r � SchedulerBase�DisposableBaser �r r% �r r r �r r � do_action s ��)z do_action_.<locals>.do_action)r r )r r r r. r r, r � do_action_ s Er/ )r r c C s t | j| j| j�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. >>> 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 )z�Invokes 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� j�S )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.<locals>.subscribe.<locals>.on_next)r r% r r )r r r �r1 r r& r r% t s z do_after_next.<locals>.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 )z�Invokes 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|d�S �Nr$ )r% r r r )r r �r5 r r r r% � s �z"do_on_subscribe.<locals>.subscribe)N�r r( r r r) r* r )r r5 r% r r7 r �do_on_subscribe� s � � r9 )r � on_disposec sF G �fdd�dt j�� dt jt tt j t jd�� �fdd� }t|�S )z�Invokes 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.<locals>.OnDisposeNr! c s � � d S r r ��self�r: r r �dispose� s z(do_on_dispose.<locals>.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.<locals>.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|||d�S )Nc sD z �� W n, t k r6 } z� �| � W 5 d } ~ X Y n X � �� d S r )r r r ��err�r rG r r r � s z8do_on_terminate.<locals>.subscribe.<locals>.on_completed�r 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.<locals>.subscribe.<locals>.on_errorr$ �r r% r �r r r r �rG r r& r r% � s �z"do_on_terminate.<locals>.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|||d�S )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.<locals>.subscribe.<locals>.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.<locals>.subscribe.<locals>.on_errorr$ rM rN �rQ r r& r r% � s �z%do_after_terminate.<locals>.subscribe)Nr8 )r rQ r% r rS r �do_after_terminate� s � �rT )�finally_actionr c s8 G �fdd�dt 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 d�dd�Zdd�� fdd� ZdS )z do_finally.<locals>.OnDispose�� was_invokedc S s || _ d S r rV )r< rW r r r �__init__ s z&do_finally.<locals>.OnDispose.__init__Nr! c s | j d s� � d| j d< d S �Nr TrV r; �rU r r r> s z%do_finally.<locals>.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 �� � z�d s � � d�d< 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.<locals>.partial.<locals>.subscribe.<locals>.on_completedrK c sV �� | � z�d s"� � d�d< W n, tk rP } z�� |� W 5 d }~X Y nX d S rY r rL r\ r r r ( s z@do_finally.<locals>.partial.<locals>.subscribe.<locals>.on_errorr$ )r r rC r% r )r r r r rD rE )rB rU r )r rW r r% s � z.do_finally.<locals>.partial.<locals>.subscribe)Nr' r+ �rB rU r- r �partial s ��!zdo_finally.<locals>.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 �<module> sB � � M( � #"� B�
💾 Save Changes
❌ Cancel