The 范围 运算符会按顺序发出一个范围内的连续整数,您可以选择范围的起始位置及其长度。
范围
待定
RxGroovy 将此运算符实现为 范围。它接受范围的起始值和范围中项目数量作为参数。如果您将该项目数量设置为零,则生成的可观察对象将不会发出任何值(如果您将其设置为负数,则 范围 将导致异常)。
范围 默认情况下不会在任何特定的 调度器 上运行,但有一个变体允许您通过将调度器作为参数传递来设置调度器。
// myObservable emits the integers 5, 6, and 7 before completing: def myObservable = Observable.range(5, 3);
范围(int,int)
范围(int,int,调度器)
RxJava 将此运算符实现为 范围。它接受范围的起始值和范围中项目数量作为参数。如果您将该项目数量设置为零,则生成的可观察对象将不会发出任何值(如果您将其设置为负数,则 范围 将导致异常)。
间隔范围 范围
RxJS 将此运算符实现为 范围。它接受范围的起始值和范围中项目数量作为参数。
范围 默认情况下在 currentThread 调度器 上运行,但有一个变体允许您通过将调度器作为可选的第三个参数传递来设置调度器。
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
范围 存在于以下每个发行版中
rx.js
rx.compat.js
rx.lite.js
rx.lite.compat.js
RxPHP 将此运算符实现为 范围。
使用指定的调度器生成指定范围内整数的可观察序列,以发送观察者消息。
//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!