Rxjava学习

Rxjava:异步、简洁（逻辑）。

异步实现：观察者模式实现。

RxJava 有四个基本概念：Observable (可观察者，即被观察者)、 Observer (观察者)、 subscribe (订阅)、事件。Observable 和 Observer 通过 subscribe() 方法实现订阅关系，从而 Observable 可以在需要的时候发出事件来通知 Observer。

Rxjava简单例子：

```

public class MainActivityextends AppCompatActivity {

@Override

    protected void onCreate(Bundle savedInstanceState) {

     super.onCreate(savedInstanceState);

setContentView(R.layout.activity_main);

//被观察者

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

@Override

 public void subscribe(ObservableEmitter e)throws Exception {

e.onNext("hello");

e.onComplete();

}

});

//观察者

io.reactivex.Observer observer =new io.reactivex.Observer() {

@Override

            public void onSubscribe(Disposable d) {

}

@Override

            public void onNext(Object value) {

Log.i("test","onnext------------------------------>");

}

@Override

            public void onError(Throwable e) {

}

@Override

            public void onComplete() {

}

};

//注册

observable.subscribe(observer);

}

}

```

```

迷之RxJava —— subscribeOn 和 observeOn 的区别

```