[RxJava]在学习RxJava中的错误理解
2024-04-12 09:12:47
关于RxJava语法的问题与理解
最近看到一个blog-RxJava 写到关于Observable数据异步加载的介绍。针对fromCallable和just操作符在使用上的问题来跟大家针对代码进行分析一下：
代码思想
/**
* 数据获取
**/
String getMessage() {
Log.d("RxJava", Thread.currentThread().getName());
return "getMessage";
}
/**
* 订阅
**/
Subscriber<Object> getSubscriber() {
return new Subscriber<Object>() {
@Override
public void onCompleted() {
Log.d("RxJava", "onCompleted");
}
@Override
public void onError(Throwable e) {
Log.d("RxJava", "onError : " + e.toString());
}
@Override
public void onNext(Object o) {
Log.d("RxJava", "onNext : " + o);
Log.d("RxJava", Thread.currentThread().getName());
}
};
}
使用fromCallable操作符
public void run() {
Observable<String> o = Observable.fromCallable(new Callable<String>() {
@Override
public String call() throws Exception {
return getMessage();
}
});
o.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(getSubscriber());
}
使用just操作符
public void run() {
Observable<String> o = Observable.just(getMessage());
o.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(getSubscriber());
}
执行结果上，使用fromCallable时，getMessage是在子线程执行，而just是在主线程执行。
原作者给出的结论是
使用Observable.fromCallable()方法有两点好处：
1.获取要发送的数据的代码只会在有Observer订阅之后执行。
2.获取数据的代码可以在子线程中执行。
我觉得这样的结论是有问题，我来修改一个代码，来分析一下：
Observable<String> getObservable(final String s) {
return Observable.fromCallable(new Callable<String>() {
@Override
public String call() throws Exception {
return s;
}
});
}
public void run() {
Observable<String> o = Observable.getObservable(getMessage());
o.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(getSubscriber());
}
执行结果发现，getMessage是在主线程执行。
为什么是这样呢？其实这就是Java语言的调用顺序的问题而不是操作符的功能。希望大家学习Rxjava的过程中，不要脱离原有的Java语言结构，毕竟Rajva的源码也是Java语言写出来的。
最新文章
- dubbo源码分析6-telnet方式的管理实现
- word使用技巧-批量删除图片技巧
- Java反射机制及IoC原理
- 刀锋上前行！绕过Ramint蠕虫病毒直接脱壳
- Linux下U盘变成只读
- hdu 4268 multiset+贪心
- SqlServer中quotename用法与实例
- 如何使weblogic11g类似weblogic923一样统一使用一个boot.properties文件
- Java序列化接口的作用总结
- 项目升级，为了热更新使用lua。
- 安全控件开发原理分析 支付宝安全控件开发 C++
- SQL 关于有单引号数据更新的问题
- SQL Server 2008空间数据应用系列十：使用存储过程生成GeoRSS聚合空间信息
- fedora 使用trove的redstack 安装openstack环境
- codeforces 665C Simple Strings
- ionic3 小记录
- python编程从入门到实践 alien invasion 项目源码
- MongoDB从3.0.6升级到MongoDB3.4.9
- springside
- GC 提前晋升