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

Flowable.range介绍

[英]Returns a Flowable that emits a sequence of Integers within a specified range.

Backpressure: The operator honors backpressure from downstream and signals values on-demand (i.e., when requested). Scheduler: range does not operate by default on a particular Scheduler.
[中]返回在指定范围内发出整数序列的可流动项。
背压：操作员接受来自下游的背压，并按需（即，当要求时）发送信号。调度程序：默认情况下，范围不会在特定调度程序上运行。

代码示例

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

@Override
  public Publisher<Integer> apply(Integer t) {
    return Flowable.range(t, 2);
  }
})

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

@Override
  public Flowable<Integer> apply(Integer v) {
    return Flowable.range(v, 2);
  }
}).subscribe(ts);

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

@Override
  public Publisher<Integer> createPublisher(long elements) {
    return
        Flowable.range(0, (int)elements).timeout(1, TimeUnit.DAYS)
    ;
  }
}

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

@Override
  public Publisher<Integer> createPublisher(long elements) {
    return
        Flowable.range(0, (int)elements).onBackpressureBuffer()
    ;
  }
}

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

@Override
  public Publisher<Integer> createPublisher(long elements) {
    return
        Flowable.range(0, (int)elements).publish().autoConnect()
    ;
  }
}

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

@Override
public Publisher<Integer> createPublisher(final long elements) {
  return
      Flowable.range(1, 1000).reduce(new BiFunction<Integer, Integer, Integer>() {
        @Override
        public Integer apply(Integer a, Integer b) throws Exception {
          return a + b;
        }
      }).toFlowable()
    ;
}

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

@Override
public Publisher<Boolean> createPublisher(final long elements) {
  return
      Flowable.range(1, 1000).any(new Predicate<Integer>() {
        @Override
        public boolean test(Integer e) throws Exception {
          return e == 500;
        }
      }).toFlowable()
    ;
}

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

@Override
  public Publisher<Integer> createPublisher(long elements) {
    return
        Flowable.range(0, (int)elements).doAfterNext(Functions.emptyConsumer())
    ;
  }
}

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

@SuppressWarnings("unchecked")
@Test
public void bufferTimeSkipDefault() {
  Flowable.range(1, 5).buffer(1, 1, TimeUnit.MINUTES)
  .test()
  .assertResult(Arrays.asList(1, 2, 3, 4, 5));
}

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

@Override
  public Flowable<Integer> apply(Integer t) {
    return Flowable.range(1, Flowable.bufferSize() * 2)
        .doOnNext(new Consumer<Integer>() {
          @Override
          public void accept(Integer t) {
            count.getAndIncrement();
          }
        }).hide();
  }
}).subscribe(ts);

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

@Test
public void range() {
  Flowable.range(1, 5)
  .throttleLatest(1, TimeUnit.MINUTES)
  .test()
  .assertResult(1);
}

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

@Test
public void rangeEmitLatest() {
  Flowable.range(1, 5)
  .throttleLatest(1, TimeUnit.MINUTES, true)
  .test()
  .assertResult(1, 5);
}

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

@SuppressWarnings("unchecked")
@Test
public void badParallelismStage() {
  TestSubscriber<Integer> ts = new TestSubscriber<Integer>();
  Flowable.range(1, 10)
  .parallel(2)
  .subscribe(new Subscriber[] { ts });
  ts.assertFailure(IllegalArgumentException.class);
}

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

@Test
public void awaitCountLess3() {
  Flowable.range(1, 4).delay(50, TimeUnit.MILLISECONDS)
  .test()
  .awaitCount(5, TestWaitStrategy.SLEEP_1MS)
  .assertResult(1, 2, 3, 4);
}

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

@Test
  public void timedDefaultScheduler() {
    Flowable.range(1, 5).take(1, TimeUnit.MINUTES)
    .test()
    .awaitDone(5, TimeUnit.SECONDS)
    .assertResult(1, 2, 3, 4, 5);
  }
}

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

@Test
public void delayErrorCancelBackpressured() {
  TestSubscriber<Integer> ts = Flowable.range(1, 3)
  .parallel(1)
  .sequentialDelayError(1)
  .test(0);
  ts
  .cancel();
  ts.assertEmpty();
}

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

@Test
public void emptyInner() {
  Flowable.range(1, 5)
  .switchMap(Functions.justFunction(Flowable.empty()))
  .test()
  .assertResult();
}

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

@Test
public void simple() {
  Flowable.range(1, 5)
  .concatMapCompletable(Functions.justFunction(Completable.complete()))
  .test()
  .assertResult();
}

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

@Test
public void rangeSource() {
  TestSubscriber<Integer> ts = TestSubscriber.create(0);
  TestingDeferredScalarSubscriber ds = new TestingDeferredScalarSubscriber(ts);
  ds.subscribeTo(Flowable.range(1, 10));
  ts.assertNoValues();
  ts.request(1);
  ts.assertValue(10);
  ts.assertNoErrors();
  ts.assertComplete();
}

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

@Test
public void testBackpressure1() {
  TestSubscriber<Integer> ts = new TestSubscriber<Integer>();
  Flowable.range(1, 100000).takeLast(1)
  .observeOn(Schedulers.newThread())
  .map(newSlowProcessor()).subscribe(ts);
  ts.awaitTerminalEvent();
  ts.assertNoErrors();
  ts.assertValue(100000);
}