[置顶] RxJava的Subscriber使用，封装加载进度条ProgressSubscriber

最近看了一篇文章刚开始学习RxJava，鉴于边学边用；发现当我在请求网络时老是需要手动显示与关闭LadingDialog，因此我在这里把LadingDialog封装到Subscriber中。

1.继承Subscriber

public class ProgressSubscriber<T> extends Subscriber<T> implements ProgressCancelListener {

private SubscribeOnNextListener mOnNextListener;
private Context mContext;
private ProgressHandler mProgressHandler;
private boolean mUnsubscribable = false;//dialog被cancel掉的时候，是否取消掉事件监听

public ProgressSubscriber(Context context, String text, SubscribeOnNextListener listener){
mOnNextListener = listener;
mContext = context;
mProgressHandler = new ProgressHandler(mContext, this, false, text);
}

public ProgressSubscriber(Context context, boolean cancelable, String text, SubscribeOnNextListener listener){
mOnNextListener = listener;
mContext = context;
mProgressHandler = new ProgressHandler(mContext, this, cancelable, text);
}

public ProgressSubscriber(Context context, boolean cancelable, boolean unsubscribable, String text, SubscribeOnNextListener listener){
mOnNextListener = listener;
mContext = context;
mUnsubscribable = unsubscribable;
mProgressHandler = new ProgressHandler(mContext, this, cancelable, text);
}

public void showProgressDialog(){
mProgressHandler.initProgressDialog();
}

public void dismissProgressDialog(){
mProgressHandler.dismissProgressDialog();
}

@Override
public void onStart() {
super.onStart();
showProgressDialog();
}

@Override
public void onCompleted() {
dismissProgressDialog();
}

@Override
public void onError(Throwable e) {
dismissProgressDialog();
mOnNextListener.onError(e);
}

@Override
public void onNext(Object o) {
mOnNextListener.onNext(o);
}

@Override
public void onProgressCanceled() {//取消请求
if(mUnsubscribable && !isUnsubscribed()){
unsubscribe();
}
}
}

2.LoadingDialog的显示与消失

public class ProgressHandler /*extends Handler*/ {
public static final int SHOW_PROGRESS = 0;
public static final int DISMISS_PROGRESS = 1;
private CommonLoadingDialog mDialog;
private Context mContext;
private ProgressCancelListener mProgressCancelListener;
private boolean cancelable;
private String mText;

public ProgressHandler(Context context, ProgressCancelListener listener, boolean cancelable, String text){
this.mContext = context;
mProgressCancelListener = listener;
this.cancelable = cancelable;
this.mText = text;
}

public void initProgressDialog(){
if(mDialog == null){
mDialog = new CommonLoadingDialog(mContext);
mDialog.setCancelable(cancelable);
mDialog.setCanceledOnTouchOutside(false);
mDialog.setMessage(mText);
if(cancelable){
mDialog.setOnCancelListener(new DialogInterface.OnCancelListener() {
@Override
public void onCancel(DialogInterface dialog) {
mProgressCancelListener.onProgressCanceled();
}
});
}
if(!mDialog.isShowing()){
mDialog.show();//显示进度条
}
}
}

public void dismissProgressDialog(){
if(mDialog!=null){
mDialog.dismiss();//取消进度条
mDialog = null;
}
}

}

3.取消dialog监听

public interface ProgressCancelListener {
void onProgressCanceled();
}

4.Subscriber事件监听

public interface SubscribeOnNextListener<T> {
void onNext(T t);
void onError(Throwable e);
}

5.封装后的使用

public void updateWechatGoodsType(Context context, String userName, String userPwd, String merchantId, String fCategoryId, Device device) {
mModel.updateWechatGoodsType(userName, userPwd, merchantId, fCategoryId, device,
new ProgressSubscriber(context, true, context.getString(R.string.deal_with_content),
new SubscribeOnNextListener<ResultModel>() {
@Override
public void onNext(ResultModel resultModel) {
if(iView.get()!=null) {
iView.get().handleCommand(resultModel);
}
}

@Override
public void onError(Throwable e) {

}
}));
}