🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 17:55:10 | 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: _subscribeon.cpython-38.pyc
Read Only
U v�i� � @ sr d dl mZmZmZmZ d dlmZmZ d dlm Z m Z m Z ed�Z ej eee gee f d�dd�ZdgZdS ) � )�Any�Callable�Optional�TypeVar)� Observable�abc)�ScheduledDisposable�SerialDisposable�SingleAssignmentDisposable�_T)� scheduler�returnc s t t t t d�� fdd� }|S )N)�sourcer c s, dt jt tt j d��� fdd� }t|�S )a� Subscribe on the specified scheduler. Wrap the source sequence in order to run its subscription and unsubscription logic on the specified scheduler. This operation is not commonly used; see the remarks section for more information on the distinction between subscribe_on and observe_on. This only performs the side-effects of subscription and unsubscription on the specified scheduler. In order to invoke observer callbacks on a scheduler, use observe_on. Args: source: The source observable.. Returns: The source sequence whose subscriptions and un-subscriptions happen on the specified scheduler. N)�observer�_c sB t � }t� � |� _dtjtt d�� ��fdd� }��|�|_� S )N�r �statec s t | ������ _d S )N)r � subscribe� disposabler )�dr r � �Q/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_subscribeon.py�action, s �zFsubscribe_on_.<locals>.subscribe_on.<locals>.subscribe.<locals>.action)N)r r r r � SchedulerBaser r Zschedule)r r �mr )r r )r r r r % s z6subscribe_on_.<locals>.subscribe_on.<locals>.subscribe)N)r Z ObserverBaser r r r )r r �r )r r � subscribe_on s � �z#subscribe_on_.<locals>.subscribe_on)r r )r r r r r � subscribe_on_ s &r N)�typingr r r r Z reactivexr r Zreactivex.disposabler r r r r r �__all__r r r r �<module> s � ,
💾 Save Changes
❌ Cancel