- iOS/Objective-C 元类和类别
- objective-c - -1001 错误,当 NSURLSession 通过 httpproxy 和/etc/hosts
- java - 使用网络类获取 url 地址
- ios - 推送通知中不播放声音
假设我们使用 .create()
从 SharedPrefs
获取一个通用的 Object
:
return Observable.create(subscriber -> {
String json = sharedPreferences.getString(key, "");
T myClass = gson.fromJson(json, generic);
subscriber.onNext(myClass);
subscriber.onComplete();
});
并使用 .fromCallable()
:
return Observable.fromCallable(() -> {
String json = sharedPreferences.getString(key, "");
return gson.fromJson(json, generic);
});
如果我们在第一次从 Observable.create()
发出并使用 Observable.fromCallable()
后立即调用 onComplete()
有什么不同吗>?如果是这样,优点/缺点
是什么?
最佳答案
Observable.create
让您发射多个项目,而 fromCallable
仅发射一个项目。
您应该使用后者,因为它更能表达具有单个元素序列的 Intent 并且开销略低。
缺点是您不能使用它来使用异步单元素源,而 create
让您可以将对 onNext
的调用延迟到稍后的时间点。
关于android - Observable.create() 和 Observable.fromCallable() 的区别,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/43785961/
我正在使用 Spring webflux 和项目 react 器在家庭项目中试用 kotlin。我正在尝试对 H2 数据库进行阻塞调用,因此我按照建议使用 fromCallable 方法。根据我的理解
我正在尝试使用 Project Reactor 的 Mono.fromCallable(Callable) 执行异步操作,我注意到,在我的测试用例中,它似乎在调用线程上运行。是否在某处记录了 Mono
fromCallable和 defer有不同的实现。我听有人说defer有助于递归,但我无法生成任何显示它们之间差异的代码。 我尝试了无限数量的实现: private Observable numbe
我是使用 rxjava 的新手,我正在尝试使用 rxjava2 在后台运行一个函数,但是该方法没有被调用我正在使用的代码在下面给出让我知道它是否是在后台执行函数的正确方法: Observable.fr
Observable.fromCallable() 非常适合将单个函数转换为 Observable。但是,您如何处理函数可能抛出的已检查异常? 我见过的大多数示例都使用 lambda 表达式并“正常工
我试图理解这两种方法之间的区别,但它们对我来说似乎很相似。甚至 javadoc 也几乎相同 最佳答案 区别在于您在方法中使用的参数之间的差异。 如果您使用 Callable ,它会计算结果,如果无法计
我试图理解这两种方法之间的区别,但它们对我来说似乎很相似。甚至 javadoc 也几乎相同 最佳答案 区别在于您在方法中使用的参数之间的差异。 如果您使用 Callable ,它会计算结果,如果无法计
下面两种执行方式有什么区别? Mono.justOrEmpty(someFunction()) .doOnNext(() -> doSomeTask()).subscribe(); Mono.fr
下面两种执行方式有什么区别? Mono.justOrEmpty(someFunction()) .doOnNext(() -> doSomeTask()).subscribe(); Mono.fr
我一直在尝试在 Android 中使用 RxJava,但我试图找出 fromCallable 和 Just 之间的区别。两者都只接收一次数据,而 Create 可以多次接收数据。这是我用来试验的代码:
假设我们使用 .create() 从 SharedPrefs 获取一个通用的 Object: return Observable.create(subscriber -> { String
我想知道是否有人可以阐明这个问题,什么时候使用 Single.fromCallable( ()-> myObject ) 代替 Single.just(myObject) 根据文档,Single.fr
我想做如下的事情。在 Mono.fromCallable 中,我运行一些 block 逻辑,然后根据值返回 Mono.empty() 或值,以便它触发映射或 defaultIfEmpty。
我正在开发一个使用 RxJava 1.0 的 Spring Boot 应用程序,并且我正在使用 Groovy 编程语言使用 IntelliJ IDE 构建它。我似乎无法让它接受我的 Observabl
在以下两个示例中,第一个示例(使用 map())告诉我 readTree() 存在未处理的异常,但第二个示例则不然例子。为什么这样 ?谢谢! Mono.just(jsonString) .map(js
我们什么时候应该使用 Completable.fromAction()我们什么时候应该使用 Completable.fromCallable()是否有特定的用例 从文档看来,两者都做同样的事情,很难注
我通常需要生成一个 Mono/Flux,其值将在订阅时生成/计算。为此, fromCallable 和 defer 运算符似乎都很好。 我无法在 javadoc 中清楚地看到差异: FromCalla
我在我的应用程序中使用 RxJava 和 AWS API Gateway。 代码在这里: @Override public Single searchPostsApiCall(Stri
我是一名优秀的程序员,十分优秀!