🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 09:17:24 | PHP 8.2.32
📂
/ (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: returnvalue.cpython-38.pyc
Read Only
U v�i� � @ s� d dl mZmZmZmZ d dlmZmZ d dlm Z ed�Z d e eej ee d�dd�Z d eg e f eej ee d �d d �Z dd gZdS )� )�Any�Callable�Optional�TypeVar)� Observable�abc)�CurrentThreadScheduler�_TN)�value� scheduler�returnc s0 dt jt tt j t jd�� �fdd� }t|�S )a� Returns an observable sequence that contains a single element, using the specified scheduler to send out observer messages. There is an alias called 'just'. Examples: >>> res = return(42) >>> res = return(42, rx.Scheduler.timeout) Args: value: Single element in the resulting observable sequence. Returns: An observable sequence containing the single specified element. N��observer� scheduler_r c s6 �p|pt �� }dtjtd d�� �fdd� }|�|�S )N)r �stater c s � � �� � �� d S �N)�on_next� on_completed)r r )r r � �Q/opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/returnvalue.py�action! s z0return_value_.<locals>.subscribe.<locals>.action)N�r Z singletonr � SchedulerBaser Zschedule�r r Z _schedulerr �r r �r r � subscribe s z return_value_.<locals>.subscribe)N�r Z ObserverBaser r r ZDisposableBaser )r r r r r r � return_value_ s � � r )�supplierr r c s0 dt jt tt j t jd�� �fdd� }t|�S )Nr c s6 �p|pt �� }dtjtd d�� �fdd� }|�|�S )N)�_�__r c sJ z� � �� � � �� W n, tk rD } z� �|� W 5 d }~X Y nX d S r )r r � ExceptionZon_error)r r! �e)r r r r r 2 s z1from_callable_.<locals>.subscribe.<locals>.action)Nr r �r r r r r - s z!from_callable_.<locals>.subscribe)Nr )r r r r r$ r �from_callable_* s � �r% )N)N)�typingr r r r Z reactivexr r Zreactivex.schedulerr r r r r% �__all__r r r r �<module> s � � " � �
💾 Save Changes
❌ Cancel