Llamo a una API usando Retrofit 2 y RxJava2. Si falla una llamada, en algunos casos (por ejemplo, sin conexión a Internet), quiero mostrar un diálogo de error al usuario y dejar que vuelva a intentarlo.

Como estoy usando RxJava, estaba pensando en usar.retryWhen(...) pero no sé cómo hacerlo, ya que debe esperar a que el usuario presione el botón en el cuadro de diálogo.

En este momento, visualizo el cuadro de diálogo pero vuelve a intentarlo antes de que el usuario presione cualquier botón. Además, me gustaría que la llamada no se vuelva a intentar cuando el usuario presiona 'cancelar'.

Aquí está el código que tengo en este momento:

private void displayDialog(DialogInterface.OnClickListener positive, DialogInterface.OnClickListener negative) {
    AlertDialog.Builder builder = new AlertDialog.Builder(MainActivity.this);
    builder.setMessage("Unexpected error, do you want to retry?")
            .setPositiveButton("Retry", positive)
            .setNegativeButton("Cancel", negative)
            .show();
}

private Observable<Boolean> notifyUser() {
    final PublishSubject<Boolean> subject = PublishSubject.create();
    displayDialog(
            (dialogInterface, i) -> subject.onNext(true),
            (dialogInterface, i) -> subject.onNext(false)
    );

    return subject;
}

private void onClick() {
    Log.d(TAG, "onClick");
    getData()
            .observeOn(AndroidSchedulers.mainThread())
            .subscribeOn(Schedulers.io())
            .retryWhen(attempts -> {
                return attempts.zipWith(
                        notifyUser(),
                        (throwable, res) -> res);
            })
            .subscribe(
                    s -> {
                        Log.d(TAG, "success");
                    });
}