🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-08 09:18:15 | 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: range.cpython-38.pyc
Read Only
U v�ig � @ sx d dl mZ d dlmZmZ d dlmZmZ d dlm Z d dl m Z d e ee ee eej ee d�dd �Zd gZdS ) � )�maxsize)�Iterator�Optional)� Observable�abc)� MultipleAssignmentDisposable)�CurrentThreadSchedulerN)�start�stop�step� scheduler�returnc s� |dkr t n|}|dkr dn|}|dkr:|dkr:t| �� n |dkrNt| |�� n t| ||�� dtjt ttj tjd�� �fdd� }t|�S )a� Generates an observable sequence of integral numbers within a specified range, using the specified scheduler to send out observer messages. Examples: >>> res = range(10) >>> res = range(0, 10) >>> res = range(0, 10, 1) Args: start: The value of the first integer in the sequence. stop: [Optional] Generate number up to (exclusive) the stop value. Default is `sys.maxsize`. step: [Optional] The step to be used (default is 1). scheduler: The scheduler to schedule the values on. Returns: An observable sequence that contains a range of sequential integral numbers. N� )�observer� scheduler_r c sR �p|pt �� � t� �tjttt d d�� ���fdd� �� ��t ����_ �S )N)r �iteratorr c sL z*|s t ���t|�� � j�|d��_W n tk rF ��� Y nX d S )N)�state)�AssertionErrorZon_next�next�schedule� disposable� StopIterationZ on_completed)r r �Z _scheduler�actionr �sd� �K/opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/range.pyr 6 s z)range_.<locals>.subscribe.<locals>.action) r Z singletonr r � SchedulerBaser r �intr �iterr )r r �Zrange_tr r r � subscribe. s � zrange_.<locals>.subscribe)N) r �ranger Z ObserverBaser r r ZDisposableBaser )r r r r �_stopZ_stepr! r r r �range_ s � �r$ )NNN)�sysr �typingr r Z reactivexr r Zreactivex.disposabler Zreactivex.schedulerr r r r$ �__all__r r r r �<module> s �� =
💾 Save Changes
❌ Cancel