These are chat archives for ReactiveX/RxJava

Mar 2017
Alex Krause
Mar 18 2017 09:52
Why not do the error handling / retrying inside of the loop? Would likely be the simplest solution. Alternatively, depending on how your cursor works, you could emit the next cursor downstream and flatMap it with retry:
Alex Krause
Mar 18 2017 09:57
Flowable.create(emitter -> ... emitter.onNext(nextCursor))
         .flatMap(cursor -> Flowable.fromCallable(() -> getData(cursor))
But again, this depends on what your cursor is. If you can't get the next without reading the previous, this will likely not be possible. @ertanden