RxJava怎么使用

RxJava是一个强大的异步处理库，它可以帮助我们简化异步代码的编写。那么RxJava怎么使用呢？

首先，需要在build.gradle中添加依赖：

compile 'io.reactivex.rxjava2:rxjava:2.x.y'

其次，创建一个Observable：

Observable observable = Observable.create(new ObservableOnSubscribe() {

@Override

public void subscribe(ObservableEmitter e) throws Exception {

e.onNext(1);

e.onNext(2);

e.onNext(3);

e.onComplete();

}

});

最后，创建一个Observer来订阅Observable：

Observer observer = new Observer() {

@Override

public void onSubscribe(Disposable d) {

Log.d(TAG, "onSubscribe");

}

@Override

public void onNext(Integer value) {

Log.d(TAG, "" + value);

}

@Override

public void onError(Throwable e) {

Log.d(TAG, "onError");

}

@Override

public void onComplete() {

Log.d(TAG, "onComplete");

}

};

最后，通过调用subscribe（）方法来订阅Observable和Observer：

observable.subscribe(observer);