RxJava 学习之（一）

在学习RxJava之前，我们得先了解什么是RxJava以及有什么优点？

1.概念：

一个在 Java VM 上使用可观测的序列来组成异步的、基于事件的程序的库

2.优点

简洁。无论代码逻辑有多复杂，都能保持简洁。

书面语不多说，开始来实现hello world：

创建一个Observable对象很简单，调用Observable.create即可实现

Observable<String> mObservable = Observable.create(
new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> sub) {
sub.onNext("Hello world!");
sub.onCompleted();
}
}
);

这样hello world就创建成功了，但是这只是发出字符串，该事件并没有得到处理，再来创建一个Subscriber来处理发出的字符串

Subscriber<String> mSubscriber = new Subscriber<String>() {
@Override
public void onNext(String s) {
Log.i(TAG,s);
}

@Override
public void onCompleted() { }

@Override
public void onError(Throwable e) { }
};

最后一步，订阅，我们要将myObservable对象和mSubscriber对象进行关联，就完成了他们之间的订阅，打印hello world。

mObservable.subscribe(mSubscriber);

为什么关联起来就能打印呢，因为关联之后就会调用Subscribe的onNext()方法，该方法的参数字符串就是指定输出的hello world.

就只是打印一句话，这样写也太繁琐了，当然有更简单的方法：

Observable.just("hello world!")
.subscribe(new Action1<String>() {
@Override
public void call(String s) {
Log.i(TAG, s);
}
});

这里说一下Action1，它是RxJava的一个接口，有一个call(params),有参无返。

OK，到这里hello world就已经成功了。

[更详细：(]http://gank.io/post/560e15be2dca930e00da1083)]