solved stackoverflowerror by returning no empty flowable and using th…

…e takeWhile operator
aemaem · Aug 20, 2020 · c2391cc · c2391cc
1 parent a3a3751
commit c2391cc
Showing 1 changed file with 4 additions and 11 deletions.
diff --git a/src/main/java/SwitchIfEmptyTest.java b/src/main/java/SwitchIfEmptyTest.java
@@ -28,21 +28,14 @@ public Flowable<String> two(String input) {
             }, BackpressureStrategy.ERROR)
                     .flatMap(inputFlowable -> {
                         return source.read()
-                                .toList()
-                                .toFlowable()
-                                .flatMap(strings -> {
-                                    Flowable<String> flowable = Flowable.empty();
-                                    for (String s : strings) {
-                                        flowable = flowable.switchIfEmpty(third(s));
-                                    }
-                                    return flowable;
-                                });
+                                .flatMap(this::third)
+                                .takeWhile(s -> s.equals("false"));
                     });
         }
 
         public Flowable<String> third(String input) {
             //System.out.println("Value " + input);
-            return Flowable.empty();
+            return Flowable.just("false");
         }
     }
 
@@ -54,7 +47,7 @@ public Flowable<String> read() {
                     emitter.onNext("Some values " + i);
                 }
                 emitter.onComplete();
-            }, BackpressureStrategy.ERROR);
+            }, BackpressureStrategy.BUFFER);
         }
     }
 }