These are chat archives for ReactiveX/RxJava

18th
Mar 2017
Alex Krause
@alex0ptr
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
@alex0ptr
Mar 18 2017 09:57
Flowable.create(emitter -> ... emitter.onNext(nextCursor))
         .flatMap(cursor -> Flowable.fromCallable(() -> getData(cursor))
                                                                                                                  .retryWhen(...))
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