🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-09 01:14:07 | PHP 8.2.33
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
observable
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/__pycache__
🔄 Refresh
✏️
Editing: toasync.cpython-38.pyc
Read Only
U v�i� � @ s� d dl mZmZmZmZ d dlmZmZ d dlmZ d dl m Z d dl m Z ed�Zd edef eej edee f d �d d �Zd gZdS ) � )�Any�Callable�Optional�TypeVar)� Observable�abc)� operators)�TimeoutScheduler)� AsyncSubject�_TN.)�func� scheduler�returnc s* |p t �� � ttt d�� �fdd� }|S )a� Converts the function into an asynchronous function. Each invocation of the resulting asynchronous function causes an invocation of the original synchronous function on the specified scheduler. Examples: res = reactivex.to_async(lambda x, y: x + y)(4, 3) res = reactivex.to_async(lambda x, y: x + y, Scheduler.timeout)(4, 3) res = reactivex.to_async(lambda x: log.debug(x), Scheduler.timeout)('hello') Args: func: Function to convert to an asynchronous function. scheduler: [Optional] Scheduler to run the function on. If not specified, defaults to Scheduler.timeout. Returns: Aynchronous function. )�argsr c s< t � �dtjtd d�� ��fdd� }��|� ��t�� �S )N)r �stater c sV z �� � }W n2 t k r> } z��|� W Y �d S d }~X Y nX ��|� ��� d S )N)� ExceptionZon_errorZon_nextZ on_completed)r r �result�ex)r r �subject� �M/opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/toasync.py�action& s z*to_async_.<locals>.wrapper.<locals>.action)N)r r � SchedulerBaser Zschedule�pipe�opsZ as_observable)r r �Z _schedulerr )r r r �wrapper# s zto_async_.<locals>.wrapper)r Z singletonr r r )r r r r r r � to_async_ s r )N)�typingr r r r Z reactivexr r r r Zreactivex.schedulerr Zreactivex.subjectr r r r �__all__r r r r �<module> s � � +
💾 Save Changes
❌ Cancel