Rxjava2 取消订阅

数据源创建

fromCallable()

cerate()

注销订阅

Observable可以创建

CompositeDisposable composite = new CompositeDisposable();

订阅使用subscribeWith，要返回实现Disposable的对象；RxJava 默认实现的类即DisposableObserver，

CompositeDisposable composite = new CompositeDisposable();

Disposable disposable = Observable

       .fromCallable(new Callable<String>() {

            @Override

            public String call() throws Exception {

                return "eee";

            }

        })

        .subscribeWith(new DisposableObserver<String>() {

            @Override

            public void onNext(String s) {

            }

            @Override

            public void onError(Throwable e) {

            }

            @Override

            public void onComplete() {

            }

        });

composite.add(disposable);

另一种使用，使用Consumer

返回Disposable对象，可以取消订阅，这些方法最后调用

创建LambdaObserver,并返回，和subscribeWith有类似之处；subscribeWith是我们自己创建并返回。

LambdaObserver也实现了Dispoable接口