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)
| 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 |
no outgoing calls