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

Method setup

src/jmh/java/io/reactivex/rxjava3/core/XMapYPerf.java:97–335  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

95 Observable<Integer> obsFlatMapIterableAsObs0;
96
97 @Setup
98 public void setup() {
99 Integer[] values = new Integer[times];
100 Arrays.fill(values, 777);
101
102 Flowable<Integer> fsource = Flowable.fromArray(values);
103
104 flowFlatMapFlowable1 = fsource.flatMap(new Function<Integer, Publisher<Integer>>() {
105 @Override
106 public Publisher<Integer> apply(Integer v) {
107 return Flowable.just(v);
108 }
109 });
110
111 flowFlatMapFlowable0 = fsource.flatMap(new Function<Integer, Publisher<Integer>>() {
112 @Override
113 public Publisher<Integer> apply(Integer v) {
114 return Flowable.empty();
115 }
116 });
117
118 flowFlatMapSingle1 = fsource.flatMapSingle(new Function<Integer, SingleSource<Integer>>() {
119 @Override
120 public SingleSource<Integer> apply(Integer v) {
121 return Single.just(v);
122 }
123 });
124
125 flowFlatMapMaybe1 = fsource.flatMapMaybe(new Function<Integer, MaybeSource<Integer>>() {
126 @Override
127 public MaybeSource<Integer> apply(Integer v) {
128 return Maybe.just(v);
129 }
130 });
131
132 flowFlatMapMaybe0 = fsource.flatMapMaybe(new Function<Integer, MaybeSource<Integer>>() {
133 @Override
134 public MaybeSource<Integer> apply(Integer v) {
135 return Maybe.empty();
136 }
137 });
138
139 flowFlatMapCompletable0 = fsource.flatMapCompletable(new Function<Integer, CompletableSource>() {
140 @Override
141 public CompletableSource apply(Integer v) {
142 return Completable.complete();
143 }
144 });
145
146 flowFlatMapIterable1 = fsource.flatMapIterable(new Function<Integer, Iterable<Integer>>() {
147 @Override
148 public Iterable<Integer> apply(Integer v) {
149 return Collections.singletonList(v);
150 }
151 });
152
153 flowFlatMapIterable0 = fsource.flatMapIterable(new Function<Integer, Iterable<Integer>>() {
154 @Override

Callers

nothing calls this directly

Calls 7

fromArrayMethod · 0.95
fromArrayMethod · 0.95
flatMapMethod · 0.45
flatMapSingleMethod · 0.45
flatMapMaybeMethod · 0.45
flatMapCompletableMethod · 0.45
flatMapIterableMethod · 0.45

Tested by

no test coverage detected