🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 23:32:03 | PHP 8.2.33
📂
/ (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: _todict.cpython-38.pyc
Read Only
U v�i� � @ s� d dl mZmZmZmZmZ d dlmZmZ d dl m Z ed�Z ed�Z ed�Z d e e e f ee e e f eee geee e f f d�d d �Zd gZdS ) � )�Callable�Dict�Optional�TypeVar�cast)� Observable�abc)�Mapper�_T�_TKey�_TValueN)� key_mapper�element_mapper�returnc s* t t t tttf d�� �fdd� }|S )N)�sourcer c s: dt jtttf tt j t jd���� fdd� }t|�S )a Converts the observable sequence to a Map if it exists. Args: source: Source observable to convert. Returns: An observable sequence with a single value of a dictionary containing the values from the observable sequence. N)�observer� schedulerr c sH t � � td d���� �fdd� }d d�� �fdd� }�j|�j||d�S )N)�xr c s� z �| �}W n2 t k r> } z��|� W Y �d S d }~X Y nX � r�z � | �}W q� t k r� } z��|� W Y �d S d }~X Y q�X n tt| �}|�|< d S �N)� Exception�on_errorr r )r �key�ex�element)r r �mr � �L/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_todict.py�on_next s z=to_dict_.<locals>.to_dict.<locals>.subscribe.<locals>.on_next)r c s �� � � t� � ��� d S r )r �dict� on_completedr �r r r r r 1 s zBto_dict_.<locals>.to_dict.<locals>.subscribe.<locals>.on_completed)r )r r � subscriber )r r r r )r r r r r r! s �z,to_dict_.<locals>.to_dict.<locals>.subscribe)N) r Z ObserverBaser r r r Z SchedulerBaseZDisposableBaser )r r! �r r )r r �to_dict s ��"zto_dict_.<locals>.to_dict)r r r r r )r r r# r r" r �to_dict_ s &/r$ )N)�typingr r r r r Z reactivexr r Zreactivex.typingr r r r r$ �__all__r r r r �<module> s � � 5
💾 Save Changes
❌ Cancel