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();