我理解的Rxjava
Posted 安卓开发-顺
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了我理解的Rxjava相关的知识，希望对你有一定的参考价值。
通过两个线索来理解rxjava原理
线索一：订阅流程 subscribe
线索二：事件执行流程 以onNext为例
示例代码：
Observable.create(
new ObservableOnSubscribe<String>() {
@Override
public void subscribe(ObservableEmitter<String> emitter) throws Exception {
emitter.onNext("rxjava");
}
}
)
.map(new Function<String, String>() {
@Override
public String apply(String s) throws Exception {
return s + " map1 ";
}
})
.map(new Function<String, String>() {
@Override
public String apply(String s) throws Exception {
return s + " map2 ";
}
})
.subscribe(
new Observer<String>() {
@Override
public void onSubscribe(Disposable d) {
}
@Override
public void onNext(String s) {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onComplete() {
}
});
线索一：订阅流程 subscribe
线索二：事件执行流程 以onNext为例
以上是关于我理解的Rxjava的主要内容，如果未能解决你的问题，请参考以下文章