🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 11:28: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: _delaywithmapper.cpython-38.pyc
Read Only
U v�i� � @ s� d dl mZmZmZmZmZ d dlmZmZm Z d dl m Z m Z m Z ed�Z d eee e jeee f df ee je ee f eee gee f d�dd�ZdgZdS ) � )�Any�Callable�Optional�TypeVar�Union)� Observable�abc�typing)�CompositeDisposable�SerialDisposable�SingleAssignmentDisposable�_TN)�subscription_delay�delay_duration_mapper�returnc s" t t t t d�� �fdd� }|S )N)�sourcer c sT d�d� t �tj�r �� ��n�� dtjt ttj tjd�� ��fdd� }t|�S )a5 Time shifts the observable sequence based on a subscription delay and a delay mapper function for each element. Examples: >>> obs = delay_with_selector(source) Args: subscription_delay: [Optional] Sequence indicating the delay for the subscription to the source. delay_duration_mapper: [Optional] Selector function to retrieve a sequence indicating the delay for each given element. Returns: Time-shifted observable sequence. N)�observer� schedulerr c sl t � �dg� � ��fdd��t� �� �������fdd��� sH�� n� ��fdd��j���_t ���S )NFc s � d r�j dkr��� d S )Nr )�length� on_completed� )�at_end�delaysr r �U/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_delaywithmapper.py�done6 s zNdelay_with_mapper_.<locals>.delay_with_mapper.<locals>.subscribe.<locals>.donec sL t d d������fdd� } d d�� ��fdd� }�j| �j|�d��_d S )N)�xr c s� z�s t ����}W n2 tk rF } z��|� W Y �d S d }~X Y nX t� � ��� � td d�� ����fdd� }d d�� ����fdd� }|j|�j|�d�� _d S )N)�_r c s �� �� ��� � �� d S �N��on_next�remove�r ��dr r r r r r r H s zqdelay_with_mapper_.<locals>.delay_with_mapper.<locals>.subscribe.<locals>.start.<locals>.on_next.<locals>.on_next�r c s �� �� ��� � �� d S r r r r" r r r M s zvdelay_with_mapper_.<locals>.delay_with_mapper.<locals>.subscribe.<locals>.start.<locals>.on_next.<locals>.on_completed�r )�AssertionError� Exception�on_errorr �addr � subscribe� disposable)r �delay�errorr r )r r �mapperr r )r# r r r = s �z`delay_with_mapper_.<locals>.delay_with_mapper.<locals>.subscribe.<locals>.start.<locals>.on_nextr$ c s d� d< �� � �� d S )NTr )Zdisposer )r r � subscriptionr r r V s zedelay_with_mapper_.<locals>.delay_with_mapper.<locals>.subscribe.<locals>.start.<locals>.on_completedr% )r r* r( r+ )r r )r r r r. r r r r/ r r �start< s �zOdelay_with_mapper_.<locals>.delay_with_mapper.<locals>.subscribe.<locals>.startc s � � S r r r! )r0 r r �<lambda>c � zRdelay_with_mapper_.<locals>.delay_with_mapper.<locals>.subscribe.<locals>.<lambda>)r r r* r( r+ )r r �r. r Z sub_delay)r r r r r r0 r/ r r* / s # �z@delay_with_mapper_.<locals>.delay_with_mapper.<locals>.subscribe)N) � isinstancer ZObservableBaseZ ObserverBaser r Z SchedulerBaseZDisposableBaser )r r* �r r r3 r �delay_with_mapper s ��9z-delay_with_mapper_.<locals>.delay_with_mapper)r r )r r r6 r r5 r �delay_with_mapper_ s Ur7 )NN)r r r r r r Z reactivexr r Zreactivex.disposabler r r r ZMapperr7 �__all__r r r r �<module> s ���� `
💾 Save Changes
❌ Cancel