🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 02:12:03 | PHP 8.2.32
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/__pycache__
🔄 Refresh
✏️
Editing: run.cpython-38.pyc
Read Only
U v�i� � @ sf d dl Z d dlmZmZmZ d dlmZ d dlmZ ddl m Z e� Z ed�Z e e e d�d d �Z dS ) � N)�Optional�TypeVar�cast)� SequenceContainsNoElementsError)�NewThreadScheduler� )� Observable�_T)�source�returnc s� d�t �� �d�ttd��d� tdd���fdd� }tdd�� ��fdd� }dd �� �fd d � }| j|||td � � s���� qr�r�tt����s�t��S ) a` Run source synchronously. Subscribes to the observable source. Then blocks and waits for the observable source to either complete or error. Returns the last value emitted, or throws exception if any error occured. Examples: >>> result = run(source) Args: source: Observable source to run. Raises: SequenceContainsNoElementsError: if observable completes (on_completed) without any values being emitted. Exception: raises exception if any error (on_error) occured. Returns: The last element emitted from the observable. NF)�valuer c s | �d� d S �NT� )r )� has_result�resultr �>/opt/alt/python38/lib/python3.8/site-packages/reactivex/run.py�on_next) s zrun.<locals>.on_next)�errorr c s | �d� �� � d S r ��set)r )�done� exception�latchr r �on_error. s zrun.<locals>.on_error)r c s d� �� � d S r r r )r r r r � on_completed5 s zrun.<locals>.on_completed)� scheduler) � threading�Eventr r � Exception� subscriber �waitr )r r r r r )r r r r r r �run s r! )r �typingr r r Z reactivex.internal.exceptionsr Zreactivex.schedulerr Z observabler r r r! r r r r �<module> s
💾 Save Changes
❌ Cancel