MCPcopy Index your code
hub / github.com/ReactiveX/RxJavaComputationExpressions / whileDo

Method whileDo

src/main/java/rx/Statement.java:137–139  ·  view source on GitHub ↗

Return an Observable that replays the emissions from the source Observable so long as a condtion is true. @param preCondition the condition to evaluate before subscribing to or

(Observable<? extends T> source, Func0<Boolean> preCondition)

Source from the content-addressed store, hash-verified

135 * Observable so long as <code>preCondition</code> is true
136 */
137 public static <T> Observable<T> whileDo(Observable<? extends T> source, Func0<Boolean> preCondition) {
138 return Observable.create(new OperatorWhileDoWhile<T>(source, preCondition, preCondition));
139 }
140
141 /**
142 * Return an Observable that emits the emissions from a specified Observable

Callers 7

testWhileDoMethod · 0.95
testWhileDoOnceMethod · 0.95
testWhileDoZeroTimesMethod · 0.95
testWhileDoManyTimesMethod · 0.95

Calls

no outgoing calls

Tested by 7

testWhileDoMethod · 0.76
testWhileDoOnceMethod · 0.76
testWhileDoZeroTimesMethod · 0.76
testWhileDoManyTimesMethod · 0.76