🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 16:55:23 | 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: _observeon.cpython-38.pyc
Read Only
U v�i� � @ sf d dl mZmZmZ d dlmZmZ d dlmZ ed�Z ej eee gee f d�dd�Z dgZ dS ) � )�Callable�Optional�TypeVar)� Observable�abc)�ObserveOnObserver�_T)� scheduler�returnc s t t t t d�� fdd� }|S )N)�sourcer c s, dt jt tt j d��� fdd� }t|�S )a� Wraps the source sequence in order to run its observer callbacks on the specified scheduler. This only invokes observer callbacks on a scheduler. In case the subscription and/or unsubscription actions have side-effects that require to be run on a scheduler, use subscribe_on. Args: source: Source observable. Returns: Returns the source sequence whose observations happen on the specified scheduler. N�ZobserverZsubscribe_schedulerc s �j t� | �|d�S )N�r )� subscriber r )r r � �O/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_observeon.pyr s �z2observe_on_.<locals>.observe_on.<locals>.subscribe)N)r Z ObserverBaser r � SchedulerBaser )r r r )r r � observe_on s ��z observe_on_.<locals>.observe_on)r r )r r r r r � observe_on_ s r N) �typingr r r Z reactivexr r Zreactivex.observerr r r r �__all__r r r r �<module> s � "
💾 Save Changes
❌ Cancel