Диапазон
создать Observable, который испускает определенный диапазон последовательных целых чисел
Оператор Диапазон испускает диапазон последовательных целых чисел в порядке, где вы выбираете начало диапазона и его длину.
См. также
Информация, специфичная для языка
RxGroovy range
RxGroovy реализует этот оператор как range. Он принимает в качестве параметров начальное значение диапазона и количество элементов в диапазоне. Если вы установите это количество элементов в ноль, результирующее Observable не будет испускать значений (если вы установите его в отрицательное число, range вызовет исключение).
range по умолчанию не работает с каким-либо конкретным Планировщиком, но существует вариант, который позволяет установить Планировщик, передав его в качестве параметра.
Пример кода
// myObservable emits the integers 5, 6, and 7 before completing: def myObservable = Observable.range(5, 3);
- Javadoc:
range(int,int) - Javadoc:
range(int,int,Scheduler)
RxJava 1․x range
RxJava реализует этот оператор как range. Он принимает в качестве параметров начальное значение диапазона и количество элементов в диапазоне. Если вы установите это количество элементов в ноль, результирующее Observable не будет испускать значений (если вы установите его в отрицательное число, range вызовет исключение).
range по умолчанию не работает с каким-либо конкретным Планировщиком, но существует вариант, который позволяет установить Планировщик, передав его в качестве параметра.
- Javadoc:
range(int,int) - Javadoc:
range(int,int,Scheduler)
RxJS range
RxJS реализует этот оператор как range. Он принимает в качестве параметров начальное значение диапазона и количество элементов в диапазоне.
range по умолчанию работает с Планировщиком currentThread, но существует вариант, который позволяет установить Планировщик, передав его в качестве необязательного третьего параметра.
Пример кода
var source = Rx.Observable.range(0, 3);
var subscription = source.subscribe(
function (x) { console.log('Next: ' + x); },
function (err) { console.log('Error: ' + err); },
function () { console.log('Completed'); });
Next: 0 Next: 1 Next: 2 Completed
range содержится в каждом из следующих распределений:
rx.jsrx.compat.jsrx.lite.jsrx.lite.compat.js
RxPHP range
RxPHP реализует этот оператор как range.
Генерирует последовательность observable целых чисел в заданном диапазоне, используя указанный планировщик для отправки сообщений наблюдателю.
Пример кода
//from https://github.com/ReactiveX/RxPHP/blob/master/demo/range/range.php $observable = \Rx\Observable::range(0, 3); $observable->subscribe($stdoutObserver);
Next value: 0 Next value: 1 Next value: 2 Complete!
© ReactiveX contributors
Licensed under the Apache License 2.0.
http://reactivex.io/documentation/operators/range.html
