io.reactivex.Observable.intervalRange()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(8.6k)|赞(0)|评价(0)|浏览(490)

本文整理了Java中io.reactivex.Observable.intervalRange()方法的一些代码示例，展示了Observable.intervalRange()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Observable.intervalRange()方法的具体详情如下：
包路径：io.reactivex.Observable
类名称：Observable
方法名：intervalRange

Observable.intervalRange介绍

[英]Signals a range of long values, the first after some initial delay and the rest periodically after.

The sequence completes immediately after the last value (start + count - 1) has been reached.

Scheduler: intervalRange by default operates on the Schedulers#computation() Scheduler.
[中]发出一系列长值的信号，第一个在一些初始延迟之后，其余的在延迟之后周期性地发出。
序列在达到最后一个值（开始+计数-1）后立即完成。
调度器：intervalRange默认在调度器#computation（）调度器上运行。

代码示例

代码示例来源：origin: alibaba/Tangram-Android

  1. /**
  2.  * return tick observable for each user, user should handle the observable with cell's lifecycle
  3.  * @param interval timer interval, in TimeUnit.SECOND
  4.  * @param total total event count
  5.  * @param intermediate true, get event immediately
  6.  * @return
  7.  * @since 3.0.0
  8.  */
  9. public Observable<Long> getTickObservable(int interval, int total, boolean intermediate) {
  10.   return Observable.intervalRange(0, total, intermediate ? 0 : interval, interval, TimeUnit.SECONDS);
  11. }

代码示例来源：origin: alibaba/Tangram-Android

  1. /**
  2.  * return tick observable for each user, user should handle the observable with cell's lifecycle
  3.  * @param interval timer interval, in TimeUnit.SECOND
  4.  * @param total total event count
  5.  * @param intermediate true, get event immediately
  6.  * @return
  7.  * @since 3.0.0
  8.  */
  9. public Observable<Long> getTickObservable(int interval, int total, boolean intermediate) {
  10.   return Observable.intervalRange(0, total, intermediate ? 0 : interval, interval, TimeUnit.SECONDS);
  11. }

代码示例来源：origin: ReactiveX/RxJava

  1. @Test
  2. public void longOverflow() {
  3.   Observable.intervalRange(Long.MAX_VALUE - 1, 2, 1, 1, TimeUnit.MILLISECONDS);
  4.   Observable.intervalRange(Long.MIN_VALUE, Long.MAX_VALUE, 1, 1, TimeUnit.MILLISECONDS);
  5.   try {
  6.     Observable.intervalRange(Long.MAX_VALUE - 1, 3, 1, 1, TimeUnit.MILLISECONDS);
  7.     fail("Should have thrown!");
  8.   } catch (IllegalArgumentException ex) {
  9.     assertEquals("Overflow! start + count is bigger than Long.MAX_VALUE", ex.getMessage());
  10.   }
  11. }

代码示例来源：origin: ReactiveX/RxJava

  1. @Test(expected = NullPointerException.class)
  2. public void intervalRangeUnitNull() {
  3.   Observable.intervalRange(1, 1, 1, 1, null);
  4. }

代码示例来源：origin: ReactiveX/RxJava

  1. @Test(expected = NullPointerException.class)
  2. public void intervalRangeSchedulerNull() {
  3.   Observable.intervalRange(1, 1, 1, 1, TimeUnit.SECONDS, null);
  4. }

代码示例来源：origin: ReactiveX/RxJava

  1. /**
  2.  * Signals a range of long values, the first after some initial delay and the rest periodically after.
  3.  * <p>
  4.  * The sequence completes immediately after the last value (start + count - 1) has been reached.
  5.  * <p>
  6.  * <img width="640" height="195" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/intervalRange.png" alt="">
  7.  * <dl>
  8.  *  <dt><b>Scheduler:</b></dt>
  9.  *  <dd>{@code intervalRange} by default operates on the {@link Schedulers#computation() computation} {@link Scheduler}.</dd>
  10.  * </dl>
  11.  * @param start that start value of the range
  12.  * @param count the number of values to emit in total, if zero, the operator emits an onComplete after the initial delay.
  13.  * @param initialDelay the initial delay before signalling the first value (the start)
  14.  * @param period the period between subsequent values
  15.  * @param unit the unit of measure of the initialDelay and period amounts
  16.  * @return the new Observable instance
  17.  */
  18. @CheckReturnValue
  19. @SchedulerSupport(SchedulerSupport.COMPUTATION)
  20. public static Observable<Long> intervalRange(long start, long count, long initialDelay, long period, TimeUnit unit) {
  21.   return intervalRange(start, count, initialDelay, period, unit, Schedulers.computation());
  22. }

代码示例来源：origin: ReactiveX/RxJava

  1. @Test
  2. public void dispose() {
  3.   TestHelper.checkDisposed(Observable.intervalRange(1, 2, 1, 1, TimeUnit.MILLISECONDS));
  4. }

代码示例来源：origin: ReactiveX/RxJava

  1. @Test
  2. public void countNegative() {
  3.   try {
  4.     Observable.intervalRange(1, -1, 1, 1, TimeUnit.MILLISECONDS);
  5.     fail("Should have thrown!");
  6.   } catch (IllegalArgumentException ex) {
  7.     assertEquals("count >= 0 required but it was -1", ex.getMessage());
  8.   }
  9. }

代码示例来源：origin: redisson/redisson

  1. /**
  2.  * Signals a range of long values, the first after some initial delay and the rest periodically after.
  3.  * <p>
  4.  * The sequence completes immediately after the last value (start + count - 1) has been reached.
  5.  * <p>
  6.  * <img width="640" height="195" src="https://raw.github.com/wiki/ReactiveX/RxJava/images/rx-operators/intervalRange.png" alt="">
  7.  * <dl>
  8.  *  <dt><b>Scheduler:</b></dt>
  9.  *  <dd>{@code intervalRange} by default operates on the {@link Schedulers#computation() computation} {@link Scheduler}.</dd>
  10.  * </dl>
  11.  * @param start that start value of the range
  12.  * @param count the number of values to emit in total, if zero, the operator emits an onComplete after the initial delay.
  13.  * @param initialDelay the initial delay before signalling the first value (the start)
  14.  * @param period the period between subsequent values
  15.  * @param unit the unit of measure of the initialDelay and period amounts
  16.  * @return the new Observable instance
  17.  */
  18. @CheckReturnValue
  19. @SchedulerSupport(SchedulerSupport.COMPUTATION)
  20. public static Observable<Long> intervalRange(long start, long count, long initialDelay, long period, TimeUnit unit) {
  21.   return intervalRange(start, count, initialDelay, period, unit, Schedulers.computation());
  22. }

代码示例来源：origin: ReactiveX/RxJava

  1. @Test
  2. public void simple() throws Exception {
  3.   Observable.intervalRange(5, 5, 50, 50, TimeUnit.MILLISECONDS)
  4.   .test()
  5.   .awaitDone(5, TimeUnit.SECONDS)
  6.   .assertResult(5L, 6L, 7L, 8L, 9L);
  7. }

代码示例来源：origin: ReactiveX/RxJava

  1. @Test
  2. public void countZero() {
  3.   Observable.intervalRange(1, 0, 1, 1, TimeUnit.MILLISECONDS)
  4.   .test()
  5.   .awaitDone(5, TimeUnit.SECONDS)
  6.   .assertResult();
  7. }

代码示例来源：origin: ReactiveX/RxJava

  1. @Test
  2. public void customScheduler() {
  3.   Observable.intervalRange(1, 5, 1, 1, TimeUnit.MILLISECONDS, Schedulers.single())
  4.   .test()
  5.   .awaitDone(5, TimeUnit.SECONDS)
  6.   .assertResult(1L, 2L, 3L, 4L, 5L);
  7. }

代码示例来源：origin: ReactiveX/RxJava

  1. @Test(timeout = 2000)
  2.   public void cancel() {
  3.     Observable.intervalRange(0, 20, 1, 1, TimeUnit.MILLISECONDS, Schedulers.trampoline())
  4.     .take(10)
  5.     .test()
  6.     .assertResult(0L, 1L, 2L, 3L, 4L, 5L, 6L, 7L, 8L, 9L);
  7.   }
  8. }

代码示例来源：origin: ReactiveX/RxJava

  1. @Test
  2. public void restartTimerMany() {
  3.   Observable.intervalRange(1, 1000, 1, 1, TimeUnit.MILLISECONDS)
  4.   .window(1, TimeUnit.MILLISECONDS, Schedulers.single(), 2, true)
  5.   .flatMap(Functions.<Observable<Long>>identity())
  6.   .take(500)
  7.   .test()
  8.   .awaitDone(5, TimeUnit.SECONDS)
  9.   .assertSubscribed()
  10.   .assertValueCount(500)
  11.   .assertNoErrors()
  12.   .assertComplete();
  13. }

代码示例来源：origin: zhiwei1990/android-jetpack-demo

  1. public static void doSome() {
  2.     Observable.intervalRange(0L, 5, 0, 2, TimeUnit.SECONDS)
  3. //                .interval(2, TimeUnit.SECONDS)
  4.         .subscribeOn(Schedulers.io())
  5.         .observeOn(AndroidSchedulers.mainThread())
  6.         .subscribe(aLong -> Log.i(TAG, "accept: " + aLong));
  7.   }
  8. }

代码示例来源：origin: REBOOTERS/My-MVP

  1. private void intervalRangeOperator() {
  2.   Observable.intervalRange(1, 10, 0, 500, TimeUnit.MILLISECONDS, AndroidSchedulers.mainThread())
  3.       .subscribe(new Observer<Long>() {
  4.         @Override
  5.         public void onSubscribe(Disposable d) {
  6.           mCompositeDisposable.add(d);
  7.         }
  8.         @Override
  9.         public void onNext(Long aLong) {
  10.           Log.e(TAG, "onNext: aLong=" + aLong);
  11.         }
  12.         @Override
  13.         public void onError(Throwable e) {
  14.         }
  15.         @Override
  16.         public void onComplete() {
  17.         }
  18.       });
  19. }

代码示例来源：origin: akarnokd/akarnokd-misc

  1. public static void main(String[] args) throws Exception {
  2.     System.out.println("start");
  3.     // snippt-1
  4.     Observable.intervalRange(0L, 10L, 1, 1, TimeUnit.SECONDS, Schedulers.trampoline())
  5.         .subscribe(aLong -> System.out.println(aLong + "; " + Thread.currentThread().getName()), Throwable::printStackTrace,
  6.             () -> System.out.println("complete1."));
  7.     // snippt-2
  8.     Observable.interval(1, TimeUnit.SECONDS, Schedulers.trampoline()).take(10)
  9.         .subscribe(aLong -> System.out.println(aLong + "; " + Thread.currentThread().getName()), Throwable::printStackTrace,
  10.             () -> System.out.println("complete2."));
  12.     Thread.sleep(30000);
  13.     System.out.println("end");
  14.   }
  15. }

代码示例来源：origin: imZeJun/RxSample

  1. private void startSimplePolling() {
  2.   Log.d(TAG, "startSimplePolling");
  3.   Observable<Long> observable = Observable.intervalRange(0, 5,0, 3000, TimeUnit.MILLISECONDS).take(5).doOnNext(new Consumer<Long>() {
  4.     @Override
  5.     public void accept(Long aLong) throws Exception {
  6.       doWork(); //这里使用了doOnNext，因此DisposableObserver的onNext要等到该方法执行完才会回调。
  7.     }
  8.   });
  9.   DisposableObserver<Long> disposableObserver = getDisposableObserver();
  10.   observable.subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe(disposableObserver);
  11.   mCompositeDisposable.add(disposableObserver);
  12. }

代码示例来源：origin: akarnokd/RxJava2Extensions

  1. @Test
  2. public void gating() {
  3.   Observable.intervalRange(1, 10, 17, 17, TimeUnit.MILLISECONDS)
  4.   .compose(ObservableTransformers.<Long>valve(
  5.       Observable.interval(50, TimeUnit.MILLISECONDS).map(new Function<Long, Boolean>() {
  6.     @Override
  7.     public Boolean apply(Long v) throws Exception {
  8.       return (v & 1) == 0;
  9.     }
  10.   }), true, 16))
  11.   .test()
  12.   .awaitDone(5, TimeUnit.SECONDS)
  13.   .assertResult(1L, 2L, 3L, 4L, 5L, 6L, 7L, 8L, 9L, 10L);
  14. }

内容来源于网络，如有侵权，请联系作者删除！

Observable

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    Observable类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com