根据http://gank.io/post/560e15be2dca930e00da1083#toc_16 该地址的内容，学习了一些关于Rxjava的基本用法，并非整篇文章都能看懂，这里做些总结。
一、这里记录一些关键性的词
1、Observer观察者，Observable被观察者
2、subscribe订阅，subscribe()订阅的方法
3、onNext()回调，相当于onClick()
4、onCompleted()，队列事件完结
5、onError()，事件队列异常，5和6一般都会在事件队列结尾出现，而且只有一个。
6、Subscriber，也就相当Observer的扩展
7、OnSubscribe，计划表
二、最基本的用法
1、创建Observer
Observer<String> observer = new Observer<String>() {
@Override
public void onNext(String s) {
Log.d(tag, "Item: " + s);
}
@Override
public void onCompleted() {
Log.d(tag, "Completed!");
}
@Override
public void onError(Throwable e) {
Log.d(tag, "Error!");
}
};
2、创建Observable
Observable observable = Observable.create(new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
subscriber.onNext("Hello");
subscriber.onNext("Hi");
subscriber.onNext("Aloha");
subscriber.onCompleted();
}
});
Rxjava使用create方法来创建一个Observable
这里文章中有一句话是这样说当Observable被订阅时，Onsubscribe的call方法会自动被调用
那么这里就有一个小问题了，Observable什么时候被订阅
除了用create方法创建Observable之外，还可以用just和from
Observable observable = Observable.just("Hello", "Hi", "Aloha");
String[] words = {"Hello", "Hi", "Aloha"};
Observable observable = Observable.from(words);
3、Subscribe()方法
用subscribe可以将Observable和Observer链接起来
observable.subscribe(observer);
那么什么叫链接起来，是普通观察者模式中Observer订阅Observable时将Observer加入Observable中的ObserverList的意思吗？
文章中有直接给出这个方法的核心代码，我觉得作者在这里非常的牛逼，他把一些优化的东西去除，只留下了最简单的核心实现代码给初学者看，那样简直就是十分的直观
public Subscription subscribe(Subscriber subscriber) {
subscriber.onStart();
onSubscribe.call(subscriber);
return subscriber;
}
可以看出onStart方法相当于准备操作，而这个方法中调用了call方法。是不是就可以说Observable并不是在创建时就立即发送事件，而是在它被订阅的时候。是不是也就是说，当你调用这个方法时，会马上实现回调。
这里有一张图也是画得很好：
这个条目中还说了一个这个方法可以支持不完整的回调，我看了一下，看不太懂是什么意思，再后面弄清楚之后再补上。
4、例子
先取其中一个简单的例子来进行分析吧（由Id取得图片并显示）
int drawableRes = ...;
ImageView imageView = ...;
Observable.create(new OnSubscribe<Drawable>() {
@Override
public void call(Subscriber<? super Drawable> subscriber) {
Drawable drawable = getTheme().getDrawable(drawableRes));
subscriber.onNext(drawable);
subscriber.onCompleted();
}
}).subscribe(new Observer<Drawable>() {
@Override
public void onNext(Drawable drawable) {
imageView.setImageDrawable(drawable);
}
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
Toast.makeText(activity, "Error!", Toast.LENGTH_SHORT).show();
}
});
例子虽然简单，但是他把所有的内容都混在一起写了，那我就在这里分开写更明了一些，也方便以后的更深内容。
首先创建Observer
Observer<Drawable> observer = new Observer<Drawable>(){
@Override
public void onNext(Drawable drawable) {
imageView.setImageDrawable(drawable);
}
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
Toast.makeText(activity, "Error!",Toast.LENGTH_SHORT).show();
}
}
然后创建Observable
Observable observable = Observable.create(new OnSubscribe<Drawable>() {
@Override
public void call(Subscriber<? super Drawable> subscriber) {
Drawable drawable = getTheme().getDrawable(drawableRes));
subscriber.onNext(drawable);
subscriber.onCompleted();
}
})
最后订阅
observable.subscribe(observer)。然后就执行了call中的方法
这里就是把Drawable类型传过去，所以这两个类的泛型都是使用了相同的类型。而OnSubscribe的泛型的意思像是“传递的给观察者的参数的类型”。Observer的泛型表示接收参数的类型。
剩下的博客内容会在其它地方将，这篇只是讲基础。
