Existe-t-il une méthode qui s'exécute après OnSuccess() ou onError() d'Observable?

Question

Il est très souvent que j'ai besoin de montrer un comportement de chargement dans mon application et je veux le rejeter une fois le travail effectué - peu importe si le résultat du travail est un succès ou une erreur. Par conséquent, je me retrouve avec un code comme celui-ci:

addDisposable(router.launchHomepage()        
    .compose(loadingView.show())) 
    .subscribe(
     { loadingView.dismiss() }, 
     { loadingView.dismiss() } 
    ) 
) 

Y at-il un moyen de rejeter la vue de chargement dans une seule méthode? Comme mais appelé peu importe si le résultat est le succès ou l'erreur?

Answer 1

créer la classe

import android.app.Dialog; 
import android.app.ProgressDialog; 
import android.content.Context; 
import android.support.annotation.NonNull; 
import android.support.v4.app.Fragment; 

import io.reactivex.FlowableTransformer; 
import io.reactivex.ObservableTransformer; 
import io.reactivex.SingleTransformer; 
import io.reactivex.functions.Action; 
import io.reactivex.functions.Consumer; 

public class RxShowDialogUtil { 

private ProgressDialog dialog; 
private final Context context; 

private final Consumer SUBSCRIBE_ACTION = new Consumer() { 
    @Override 
    public void accept(@NonNull Object o) throws Exception { 
     if (dialog != null && !dialog.isShowing()) { 
      dialog.show(); 
     } 
    } 
}; 

private final Action UN_SUBSCRIBE_ACTION = new Action() { 
    @Override 
    public void run() throws Exception { 
     if (dialog != null && dialog.isShowing()) { 
      dialog.dismiss(); 
     } 
     dialog = null; 
    } 
}; 

private RxShowDialogUtil(Context context) { 
    this.context = context; 
} 

public static RxShowDialogUtil createInstance(Context context) { 
    return new RxShowDialogUtil(context); 
} 

public static RxShowDialogUtil createInstance(Fragment fragment) { 
    return new RxShowDialogUtil(fragment.getActivity()); 
} 

public <T> SingleTransformer<T, T> applyDialogForSingle() { 
    createDialog(context); 
    return upstream -> upstream.doOnSubscribe(SUBSCRIBE_ACTION).doFinally(UN_SUBSCRIBE_ACTION); 
} 

public <T> ObservableTransformer<T, T> applyDialogForObservable() { 
    createDialog(context); 
    return upstream -> upstream.doOnSubscribe(SUBSCRIBE_ACTION).doFinally(UN_SUBSCRIBE_ACTION); 
} 

public <T>FlowableTransformer<T,T> applyDialogForFlowable(){ 
    createDialog(context); 
    return upstream -> upstream.doOnSubscribe(SUBSCRIBE_ACTION).doFinally(UN_SUBSCRIBE_ACTION); 
} 

private Dialog createDialog(final Context context) { 
    if (dialog == null) { 
     dialog = DialogUtils.getInstance().getProgressDialog(context); 
    } 
    return dialog; 
} 
} 

Et Utilisez

addDisposable(router.launchHomepage()        
.compose(RxShowDialogUtil.createInstance(this).applyDialogForObservable()) 
.subscribe(
    { }, 
    { } 
) 
)