single语法

  public void rxJavaSingleExample() {
        Single.just(1)
                .subscribeOn(Schedulers.io())
                .unsubscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new SingleObserver<Integer>() {
                    @Override
                    public void onSubscribe(Disposable d) {

                    }

                    @Override
                    public void onSuccess(Integer integer) {
                        LogUtils.error(TAG, "rxJavaSingleExample--:" + Thread.currentThread().getName() + "-onSuccess-:" + integer);
                    }

                    @Override
                    public void onError(Throwable e) {
                        LogUtils.error(TAG, "rxJavaSingleExample--:" + Thread.currentThread().getName() + "-onError-:" + e.toString());
                    }
                });

    }

日志

08-18 15:06:49.647 26334-26334/com.example.zhang E/MainPresenter: rxJavaSingleExample--:main-onSuccess-:1

总结

1、single只接受一个参数，多于一个会报出异常

河马过河微信公众号.jpg