Я хочу запустить метод с повторными попытками, используя RXJava

return Observable
        .just(myObj)
        .flatMap(doc ->
                myFunc(myObj, ....)
        )
        .doOnError(e -> log.Error())
        .onErrorResumeNext(myObj2 ->
                methodIWantToRunWithRetries(...)
                        .onErrorResumeNext(myObj3 ->
                                methodIWantToRunWithRetries(...)
                        )

        );
}

Если я используюonErrorResumeNext Мне нужно вкладывать его столько раз, сколько я хочу, чтобы повторить попытку.
(если я не хочу окружить это попыткой / ловить)

Есть ли возможность реализовать это с помощью методов RXJava?