MCPcopy Index your code
hub / github.com/ReactiveX/RxJava / setup

Method setup

src/jmh/java/io/reactivex/rxjava3/core/RangePerf.java:40–47  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

38 Flowable<Integer> rangeAsyncPipeline;
39
40 @Setup
41 public void setup() {
42 range = Flowable.range(1, times);
43
44 rangeAsync = range.observeOn(Schedulers.single());
45
46 rangeAsyncPipeline = range.subscribeOn(new SingleScheduler()).observeOn(Schedulers.single());
47 }
48
49 @Benchmark
50 public Object rangeSync(Blackhole bh) {

Callers

nothing calls this directly

Calls 4

rangeMethod · 0.95
singleMethod · 0.95
observeOnMethod · 0.45
subscribeOnMethod · 0.45

Tested by

no test coverage detected