2017-10-17 85 views
0

为了实践目的,我创建了stream/Observable,它以1秒周期发射值,其发射值以一秒为间隔,但在发射6后不会终止/停止,它会继续发射值。RxJava:范围运算符不工作

Observable myObservable = Observable.range(1, 6) 
      .interval(5000, TimeUnit.MILLISECONDS) 
      .observeOn(AndroidSchedulers.mainThread()); 

回答

1

interval是一种静态方法。你写的实际上只是Observable.interval(5000, TimeUnit.MILLISECONDS)。这是一个description of the difference between static and instance methods

有一个名为intervalRange的运算符,您可以在其中指定要发出的值的范围以及它们之间的延迟。

+0

我了解静态和实例方法之间的区别,想知道它是否在功能 – blackHawk

+0

和如果我想获得所需结果没有区间范围运算符 – blackHawk

+0

之间有什么区别您可以使用我在其他问题中显示的模式:https:/ /stackoverflow.com/a/46787816/61158,用'Observable.range()'替换'StringFlowable'。 – akarnokd