🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 08:12:05 | PHP 8.2.32
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
reactivex
/
testing
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/reactivex/testing/__pycache__
🔄 Refresh
✏️
Editing: coldobservable.cpython-38.pyc
Read Only
U v�i� � @ s� d dl mZmZmZmZ d dlmZmZmZ d dl m Z m Z d dl m Z ddlmZ ddlmZ ed�ZG d d � d ee �Zd S ) � )�Any�List�Optional�TypeVar)� Notification� Observable�abc)�CompositeDisposable� Disposable)�VirtualTimeScheduler� )�Recorded)� Subscription�_Tc sT e Zd Zeeee dd�� fdd� Zdee j e ee j e j d�dd�Z � ZS ) �ColdObservableN)� scheduler�messages�returnc s t � �� || _|| _g | _d S �N)�super�__init__r r � subscriptions)�selfr r �� __class__� �Q/opt/alt/python38/lib/python3.8/site-packages/reactivex/testing/coldobservable.pyr s zColdObservable.__init__)�observerr r c s� �j �t�jj�� t�j �d �t� � tt t j t d��fdd� }�j D ]:}|j }t |t�shtd��||�}� ��j�|j|�� qLd d�� ��fdd� }t|�S ) Nr )� notificationr c s" dt jtt jd�� �fdd� }|S )N)r �stater c s �r� � �� t� S r )�acceptr )r r )r r r r �action! s zBColdObservable._subscribe_core.<locals>.get_action.<locals>.action)N)r � SchedulerBaser �DisposableBase)r r! )r )r r � get_action s � �z2ColdObservable._subscribe_core.<locals>.get_actionzMust be notification)r c s< �j � j} �j��jj�}t| t|���j �< � �� d S r )r � subscriber Z to_seconds�nowr �int�dispose)�start�end)�disp�indexr r r r( 3 s z/ColdObservable._subscribe_core.<locals>.dispose)r �appendr r �clock�lenr r r r ZScheduledActionr �value� isinstance� ValueError�addZschedule_relative�timer )r r r r$ �messager r! r( r )r+ r, r r r �_subscribe_core s z ColdObservable._subscribe_core)NN)�__name__� __module__� __qualname__r r r r r r r Z ObserverBaser" r# r6 � __classcell__r r r r r s � � �r N)�typingr r r r Z reactivexr r r Zreactivex.disposabler r Zreactivex.schedulerr Zrecordedr Z subscriptionr r r r r r r �<module> s
💾 Save Changes
❌ Cancel