显示并隐藏loading

1显示并隐藏loading.java

  /**
     * 显示并隐藏loading
     */
    @SuppressWarnings("unchecked")
    public static <T> Observable.Transformer<T, T> showLoading(final ILoading loading) {
        return new Observable.Transformer<T, T>() {
            @Override
            public Observable<T> call(Observable<T> observable) {
                return observable
                        .doOnSubscribe(new Action0() {
                            @Override
                            public void call() {
                                loading.showLoading();
                            }
                        }).subscribeOn(AndroidSchedulers.mainThread())
                        .doOnTerminate(new Action0() {
                            @Override
                            public void call() {
                                loading.hideLoading();
                            }
                        }).observeOn(AndroidSchedulers.mainThread());
            }
        };
    }

ILoading.java

/**
 * Created by Andy on 4/7/2016.
 */
public interface ILoading {
    void showLoading();
    void hideLoading();
}

MainActivity.java

    @Override
    public void showLoading() {
        showLoading(getString(R.string.loading));
    }

    @Override
    public void hideLoading() {
        Observable.empty()
                .observeOn(AndroidSchedulers.mainThread())
                .doOnTerminate(new Action0() {
                    @Override
                    public void call() {
                        //todo
                    }
                })
                .subscribe();
    }


    public void showLoading(String tip) {
        Observable.just(tip)
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Action1<String>() {
                    @Override
                    public void call(String s) {
                        //todo
                    }
                });
    }

MainActivity_useit.java

model.update()
              .compose(RxUtils.<XXX>showLoading(MainActivity.this))
              .subscribe();

Seems you need to use it in loading.java :

 return observable
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.io())
                        .doOnSubscribe(new Action0() {
                            @Override
                            public void call() {
                                loading.showLoading();
                            }
                        })
.observeOn(AndroidSchedulers.io())
                        .doOnTerminate(new Action0() {
                            @Override
                            public void call() {
                                loading.hideLoading();
                            }
});

because you use .observeOn(AndroidSchedulers.mainThread()) in

 Observable.just(tip)
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Action1<String>() {
                    @Override
                    public void call(String s) {
                        //todo
                    }
});