最新发现关于RxJava的讨论越来越多,使的也越来越多,决定写篇博客来记录下RxJava的学习得。
先还是得看个代码,来了解法:
//step 1
Observable<String> observable = Observable
.create(new OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
subscriber.onNext("hello RxJava");
subscriber.onCompleted();
}
});
//step 2
Observer<String> observer = new Observer<String>() {
@Override
public void onCompleted() {
System.out.println("invoked in onCompleted ");
}
@Override
public void onError(Throwable e) {
System.out.println("invoked in onError ");
}
@Override
public void onNext(String str) {
System.out.println("invoked in onNext : " + str);
}
};
//step 3
observable.subscribe(observer);
可以看上上述3步骤,先创建 Observable ,然后创建 Observer ,最后调 subscribe 法。
ok,先运下:
RxJava 完全解析
、概述
、法