Я использую наблюдаемый метод, у которого есть диалог, и я хочу отправить сообщение о повторной попытке в случае неудачи. Но после нажатия кнопки, сообщение не повторяется. Как я могу это сделать?
getCompositeDisposable().add(repository.method().flatMap(resource -> {
getNavigator().showDialog(new Fragment.Listener() {
@Override
public void onPositiveButtonClicked() {
//observable method
}
@Override
public void onNegativeButtonClicked() {
getNavigator().finishActivity();
}
}).retryWhen(throwableFlowable -> {
AtomicInteger counter = new AtomicInteger();
return throwableFlowable.takeWhile(e -> {
return counter.getAndIncrement() != 4;
}).doOnNext(throwable -> getNavigator().showMessage("Again"));
})
}));