U
vig @ sx d dl mZ d dlmZmZ d dlmZmZ d dlm Z d dl
m Z d
e ee ee eej
ee ddd Zd gZdS ) )maxsize)IteratorOptional)
Observableabc) MultipleAssignmentDisposable)CurrentThreadSchedulerN)startstopstep schedulerreturnc 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_nextnextschedule
disposable
StopIterationZ on_completed)r r Z
_scheduleractionr sd K/opt/alt/python38/lib/python3.8/site-packages/reactivex/observable/range.pyr 6 s z)range_..subscribe..action) r Z singletonr r
SchedulerBaser r intr iterr )r r Zrange_tr r r subscribe. s
zrange_..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 s =