@@ -74,7 +74,7 @@ public Observable<Integer> call(Integer i) {
7474
7575 @ GenerateMicroBenchmark
7676 public void flatMapTwoNestedSync (final Input input ) throws InterruptedException {
77- Observable .range (1 , 10 ).flatMap (new Func1 <Integer , Observable <Integer >>() {
77+ Observable .range (1 , 2 ).flatMap (new Func1 <Integer , Observable <Integer >>() {
7878
7979 @ Override
8080 public Observable <Integer > call (Integer i ) {
@@ -84,16 +84,17 @@ public Observable<Integer> call(Integer i) {
8484 }).subscribe (input .observer );
8585 }
8686
87- @ GenerateMicroBenchmark
88- public void flatMapTenNestedAsync (final Input input ) throws InterruptedException {
89- Observable .range (1 , 10 ).flatMap (new Func1 <Integer , Observable <Integer >>() {
90-
91- @ Override
92- public Observable <Integer > call (Integer i ) {
93- return input .observable .subscribeOn (Schedulers .computation ());
94- }
95-
96- }).subscribe (input .observer );
97- }
87+ // this runs out of memory currently
88+ // @GenerateMicroBenchmark
89+ // public void flatMapTwoNestedAsync(final Input input) throws InterruptedException {
90+ // Observable.range(1, 2).flatMap(new Func1<Integer, Observable<Integer>>() {
91+ //
92+ // @Override
93+ // public Observable<Integer> call(Integer i) {
94+ // return input.observable.subscribeOn(Schedulers.computation());
95+ // }
96+ //
97+ // }).subscribe(input.observer);
98+ // }
9899
99100}
0 commit comments