【RxJava在安卓中的简单使用】 RxJava是一个好用的异步库。
我的理解是observable类产生事件，observer类异步消费事件，通过subscribe将生产和消费联系在一起。
以下代码中包含普通使用和链式使用两种方式，链式使用方式有点类似于建造者模式的调用模式，逻辑分明。
RxJava可以在代码逻辑大量增加时，保持代码的可读性。
import android.support.v7.app.AppCompatActivity;
import android.os.Bundle;
import android.util.Log;
import android.widget.Toast;
import io.reactivex.Observable;
import io.reactivex.ObservableEmitter;
import io.reactivex.ObservableOnSubscribe;
import io.reactivex.Observer;
import io.reactivex.disposables.Disposable;
public class MainActivity extends AppCompatActivity {
private final String TAG = "MainActivity";
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
if (getSupportActionBar()!=null) {
getSupportActionBar().hide();
}
setContentView(R.layout.activity_main);
//创建事件产生者
Observable observable = Observable.create(new ObservableOnSubscribe() {
@Override
public void subscribe(ObservableEmitter emitter) throws Exception {
emitter.onNext(1);
emitter.onNext(2);
emitter.onNext(3);
emitter.onComplete();
}
});
//创建事件消费者
Observer observer = new Observer() {
@Override
public void onSubscribe(Disposable d) {
Log.i(TAG, "开始盯着事件生产者，一有事件出来就吃掉");
}@Override
public void onNext(Integer value) {Toast.makeText(MainActivity.this, String.valueOf(value), Toast.LENGTH_LONG).show();
Log.i(TAG, "valuehttps://www.it610.com/article/==" + value);
}@Override
public void onError(Throwable e) {}@Override
public void onComplete() {
Log.i(TAG, "事件生产者不再生产");
}
};
//创建生产者和消费者的通道,张小黑在盯着你呢
observable.subscribe(observer);
//RxJava的链式操作
Observable.create(new ObservableOnSubscribe() {
@Override
public void subscribe(ObservableEmitter emitter) throws Exception {
emitter.onNext(1);
emitter.onNext(2);
emitter.onNext(3);
emitter.onComplete();
}
}).subscribe(new Observer() {
@Override
public void onSubscribe(Disposable d) {
Log.i(TAG, "开始盯着事件生产者，一有事件出来就吃掉");
}@Override
public void onNext(Integer value) {Toast.makeText(MainActivity.this, String.valueOf(value), Toast.LENGTH_LONG).show();
Log.i(TAG, "valuehttps://www.it610.com/article/==" + value);
}@Override
public void onError(Throwable e) {}@Override
public void onComplete() {
Log.i(TAG, "事件生产者不再生产");
}
});
}
}
