我理解的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的主要内容，如果未能解决你的问题，请参考以下文章