reJava基础篇之四--被观察者_综合

被观察者篇

rxJava的观察者Observable就是观察者，观察者决定什么时候触发事件和触发什么样
的事件，触发事件的方式有很多种。常见的就有：

（1）create()
Observable observable = Observable.create(new OnSubscribe<String>() {

@Override
public void call(Subscriber<? super String> arg0) {
subscriber.onNext("Hello");
subscriber.onNext("lol");
subscriber.onNext("dema");
subscriber.onCompleted();

}
});

（2）just(T...),将传入的参数依次发出
Observable observable = Observable.just("Hello", "lol", "dema");
里面的运行过程是：
// onNext("Hello");
// onNext("lol");
// onNext("dema");
// onCompleted();

（3）from(T[])传入的是一个数组，但是里面调用的时候还是拆分开的
String[] words = {"Hello", "lol", "dema"};
Observable observable = Observable.from(words);
里面的运行过程是：
// onNext("Hello");
// onNext("lol");
// onNext("dema");
// onCompleted();