.defer()在RxJava中做什么？
在RxJava中，.defer()是一个操作符，用于延迟创建Observable对象。它的作用是将一个Observable的创建推迟到订阅时刻，确保每个订阅者都得到一个独立的Observable。
使用.defer()操作符可以解决在创建Observable时可能存在的一些问题，例如创建Observable时需要依赖外部资源或者需要从网络或数据库获取数据。
.defer()的使用方式是将创建Observable的逻辑放在一个函数中，并在订阅时通过.defer()来调用这个函数。这样每次订阅时都会执行这个函数，确保每个订阅者都获得一个独立的Observable。
.defer()的语法如下：
Observable.defer(() -> createObservable())其中，createObservable()表示实际创建Observable的逻辑，可以根据需求进行编写。
.defer()的优势是在订阅时动态创建Observable，避免了提前创建Observable导致的资源浪费问题。它适用于需要动态生成Observable的场景，例如每次订阅时需要获取最新数据的情况。
在腾讯云中，相关产品和产品介绍链接地址如下：
相关·内容
我是rx java的新手，我不明白Completable.defer带来了什么，为什么使用它是一个很好的实践。 那么，这两者的区别是什么呢？public Completable someMethod1() {} vs public CompletablesomeMethod1() {} 我可以看到，在该方法的实现中，有一些异常处理，但这超出了我的理解。
浏览 25提问于2019-03-06得票数 4
回答已采纳
1回答
上下文:要处理Flowable<Item>，我需要先处理第一个item，然后根据这一点，要么将所有项累加到单个项(reduce)中，要么对每个项应用一个简单的映射，而不累加(map)。我不能使用缓冲区，因为即使在不应该进行积累的情况下，它也总是获取2个元素。
浏览 2提问于2022-05-08得票数 2
回答已采纳
2回答
我正在尝试将“第三方”publisher封装到RxJava中。在订阅期间，我正在准备publisher，这可能会导致异常(当publisher不可用时)。2)将其推入观察者的OnError方法？我正在考虑推送OnError，那么如何实现订阅呢？如果OnError应该是subscription中的最后一个事件，我应该将其视为subscription发生还是不发生？作为Subscription返回什么？只有NOP lambda？
浏览 2提问于2017-01-26得票数 0
1回答
我正在使用RxJava和JavaFx，我不禁注意到性能很差，每当我单击执行task的button时，button都保持突出显示，直到方法完成，应用程序的行为就像在UI线程上运行方法一样。logger.error(throwable); }
}); 我在Android中使用了RxJava，与此相比，它的性能更好。
浏览 23提问于2019-09-15得票数 1
2回答
将RxJava1代码转换为RXJava2，产生此错误，不确定我做错了什么API调用Observable<User> getUser(@Path("username") String username); public
浏览 5提问于2017-09-25得票数 1
回答已采纳
我正在将这段代码从RxJava 1迁移到RxJava 2，最初该代码使用FlatMap连续运行两个Single<Void>操作。因为它使用了一个FlatMap，所以第二个未来直到第一个完成才被创建。如何在RxJava 2中获得这种行为？
浏览 2提问于2017-09-08得票数 1
回答已采纳
这也可以在AsyncTaskLoader上完成，但是需要做的不仅仅是调用“取消”。对于AsyncTask，它还提供了进度的发布，这是我在Rx中找不到的另一件事。在一些示例中，回调比普通代码还要多。
下面是我读到的关于Rx的一些链接：
--需要取消订阅，尽管它并没有
浏览 2提问于2017-10-23得票数 1
1回答
链接反应性函数rxjava
、、、、
我有一个接口，然后创建一个实现列表，以便按顺序执行，但是这个实现是可变的，因为在以后的版本中，我们可以添加或删除几个验证。
浏览 8提问于2022-06-30得票数 0
1回答
WHERE c1 = 'something'我想做的是同时运行这两个查询，然后将结果合并到一个对象中，如下所示： public List<T> data;}
如何用RxJava解决这个问题？另外，RxJava是否适合此解决方案？
浏览 2提问于2016-11-15得票数 0
回答已采纳
2回答
我希望将同步方法从parse.com (主要是ParseObject.save() )包装到RxJava包装器中。我想出了以下几点： return Observable.defer基本上，是否有任何方法将此调用包装在RxJava中，并在保存成功时得到通知？
浏览 1提问于2016-10-22得票数 0
回答已采纳
我是RxJava2的新手，我使用了defer、concat和create等其他方法。我正在努力寻找一种实现上述内容的方法。是否有使用RxJava2 API的内置解决方案？
浏览 0提问于2017-01-31得票数 0
回答已采纳
在RxJava中使用Retrofit时，我正在尝试传递加载、成功和错误状态。我的输出是由来自Retrofit包的Response包装的，并且希望使用来自RxJava的startWith方法来传递来自Resource类的loading状态。ResponseMobileGetAccess>> getAccess(@Url String url, @FieldMap HashMap<String, Object> requestModel);
浏览 0提问于2018-05-04得票数 0
1回答
考虑以下片段：public void completableConcatTest() { .doOnCompleted(() -> System.out.println("Both completed."))}
PublishSubject<
浏览 2提问于2018-05-11得票数 0
回答已采纳
1回答
您好，我正在使用RxJava进行磁盘存储get和set操作。基本上我有一个这样的方法： return Observable.defer并且observable中的DB操作不能并发运行。我最好的选择是什么？我应该手动创建某种排序的‘ve队列吗？或者，RxJava有没有某种工具可以让我阻止这个操作，直到上一个操作完成？
浏览 0提问于2016-03-11得票数 0
在下面的代码中，我有一个嵌套的可观察的。sendMessage在flatMap中调用sendMessage函数，这也是一个可观察的函数。我还没有在Stackoverflow或其他地方找到一个示例，甚至在嵌套的可观察到的内部显示onExceptionResumeNext、onErrorResumeNext或onErrorReturnItem注意:在onExceptionResumeNext中，我现在只是返回
Observable.empty<MessageToSen
浏览 0提问于2019-07-16得票数 0
回答已采纳
我使用RxJava编写了一个存储库，在找出处理存储库写入和删除的最佳方法时遇到了麻烦。
在编写本文时，我的目标是确保任何写入或删除方法都能够从RxJava副作用方法中调用。好的，这个例子工作得很好，但是现在我有一个问题，我只需要从我的内存缓存或数据库中写入或删除数据。也就是说，我希望使用RxJava来运行同步代码，其中方法返回空。解决这个问题的一种方法是抛弃RxJava，只创建一个线程来执行任务。这是可行的，但是我使用RxJava来做所有其他的事情，所
浏览 0提问于2017-08-09得票数 0
Integer playerId = Random.nextInteger();} return Single.defer(() -> {
Integer id = Random.nextInteger();()放在lambda中
浏览 0提问于2018-04-11得票数 2
1回答
我有三个api调用，要求是
public static void main(String[] args) { getA().retry(3),
getB().onErrorResumeNext(Single.
浏览 0提问于2019-03-29得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
