🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 10:23:39 | 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: _sample.cpython-38.pyc
Read Only
U v�iK � @ s� d dl mZmZmZmZmZmZ d dlZd dlmZm Z m Z d dl m Z ed�Z ee ee ee d�dd�Z d ee jee f ee j eee gee f d �d d �Zd gZdS ) � )�Any�Callable�Optional�TypeVar�Union�castN)� Observable�abc�typing)�CompositeDisposable�_T)�source�sampler�returnc s, dt jt tt j d�� �fdd� }t|�S )N)�observer� schedulerc sx d� d�t td ��d td d�� ���fdd� }td���fdd� }� fdd �}t�j|�j||d ��j|�j||d ��S ) NF)�_r c s" �rd��� �� � r ��� d S )NF)�on_next� on_completed)r ��at_end� has_valuer �value� �L/opt/alt/python38/lib/python3.8/site-packages/reactivex/operators/_sample.py�sample_subscribe s z>sample_observable.<locals>.subscribe.<locals>.sample_subscribe�� new_valuec s d� | �d S �NTr r )r r r r r s z5sample_observable.<locals>.subscribe.<locals>.on_nextc s d� d S r r r )r r r r " s z:sample_observable.<locals>.subscribe.<locals>.on_completed�r )N)r r r r � subscribeZon_error)r r r r r �r r r r r s( ���z$sample_observable.<locals>.subscribe)N)r Z ObserverBaser r � SchedulerBaser )r r r r r! r �sample_observable s � �%r# )r r r c s" t t t t d�� �fdd� }|S )N)r r c s. t � tj�rt| � �S t| tj� �d��S dS )z�Samples the observable sequence at each interval. Examples: >>> res = sample(source) Args: source: Source sequence to sample. Returns: Sampled observable sequence. r N)� isinstancer ZObservableBaser# � reactivex�interval)r �r r r r �sample9 s �zsample_.<locals>.sample)r r )r r r( r r' r �sample_5 s r) )N)r r r r r r r r% r r Zreactivex.disposabler r r# Z RelativeTimer" r) �__all__r r r r �<module> s � - ��
💾 Save Changes
❌ Cancel