当我使用range()而不是interval()来创建一个可观察/可流动的线程时，没有必要暂停线程以实现主线程等待一段时间。在范围完成之前，Main()不会退出。同样的情况在interval()函数中没有发生。另外，当我使用range()而不是interval()来创建一个可观察/可流动的时，我必须先订阅connect()之前的观察者/
浏览 0提问于2019-01-04得票数 0
回答已采纳
2回答
我想使用一个对象的方法来转换和替换数组中的所有单词，该方法返回一个observable。我使用基于的绑定来传递正确的值。
当所有订阅完成后，我想调用另一个名为task2()的函数。我如何实现这一点？
浏览 20提问于2017-01-16得票数 0
回答已采纳
1回答
当我尝试在map函数中订阅时，可观察到的不需要等待内部订阅的执行。project.owner = owner, return project;返回的project对象包含所有者和引导it，而不是对象，因为它不等待订阅。如何使可观察到的等待所有内部订阅完成
浏览 0提问于2018-03-09得票数 1
回答已采纳
1回答
让我们假设有一组可观察的函数：B(): Observable<any>let g = forkJoin([A(), B()]);
在g上订阅之后，我可以从两个可观察到的方面获得结果。由于这个问题，如何知道我从哪一个可以观察到的结果，我的意思是A(
浏览 0提问于2018-07-06得票数 1
回答已采纳
2回答
我想订阅一个可观察的，然后执行另一个函数。我的问题是，需要一段时间才能完成请求。但是，该代码只是在订阅启动后立即继续执行。this.observable3.subscribe();this.transformShopList();
浏览 2提问于2019-03-21得票数 0
你好社区api调用在我的服务中定义。我在组件中的Lifecyclehooks中将它们命名为Lifecyclehooks，但我很难理解返回的可观测值的行为，以及如何在ngOnInit中获得它的值。我构建了一个示例代码，它记录返回的数据对象以了解它们的行为。服务函数返回可观测的。--这就是我的示例代码的样子：
我<e
浏览 5提问于2020-01-08得票数 2
回答已采纳
1回答
我目前正在学习如何使用RxJava，我希望计算从数据库中获取的数据，然后异步地计算它们，但是等待所有这些数据都被计算出来。
浏览 5提问于2017-09-14得票数 0
回答已采纳
1回答
这可能是个蹩脚的问题，但我对角度并不熟悉，对那些可观测到的东西我也不太了解。在angular2+中制作这类东西的正确方法是什么？
浏览 3提问于2020-08-21得票数 0
回答已采纳
我对RxJava并不是完全陌生的，但是我被一个看似简单的任务所阻碍。public Observable<Object> execute(String query) {
Single<RxConnection> rxConnection = getRxDBclose the connection and to wait without
浏览 5提问于2016-06-29得票数 0
回答已采纳
2回答
我还有另一个，它对同一服务器执行get，但需要第一个服务器的访问令牌才能存在。所以我希望能够在两个不同的地方同时订阅两个可观察对象，但GET observable当然必须等待POST observable。如何在另一个可观察对象订阅完成时进行可观察等待？
浏览 4提问于2016-01-06得票数 0
我有一个观察点，在某些时候必须将内容写入缓存-我们希望在完成对观察点的整个操作之前等待写入完成(出于报告目的)。出于测试目的，可完成的缓存写入如下所示： emitter -> this::finishWithSuccess
浏览 2提问于2020-02-06得票数 2
2回答
我有一个函数，它可以选择用从localStorage检索的数据来设置报头。localStorage操作返回一个承诺，我可以将其变为可观察的。startObs = Observable.empty();本质上，我希望等待startObs完成，然后返回可观察到的http.get。我试过使用类似于start
浏览 4提问于2017-05-30得票数 1
2回答
我正在用下面一个简化的测试用例复制我的Rx问题。下面的测试挂起了。我确信这是一个小的，但基本的，我缺少的东西，但不能把我的手指放在它上。在我的例子中，GetProgress()是发布下载进度的各种Observables的合并，其中一个Observables是每当有人调用方法删除下载时发布0的Subject<double>。种族条件确定的神秘和西奥多祖利亚斯可以(？)发生在现实生活中。我展
浏览 1提问于2019-12-05得票数 2
回答已采纳
1回答
我有一个返回Single<List<Item>>的方法，我想把这个列表中的每一个项目向下传递给一个返回Completable的方法。我希望等到每个项目成功完成并返回一个Completable结果。我最初的方法是使用flatMapIterable分别处理每一项，并使用toList组合结果，但不能在Completable对象上调用toList。到目前为止，我的情况如下：
public Single<List<Item>> getListOfIt
浏览 4提问于2017-08-22得票数 1
回答已采纳
我有一个可完成的和可观察的，可以发射项目的。我必须将它们组合在一起。某种Observable.combineLatest，但具有可完备性和可观察性。所以逻辑是:如果Observable首先发出项，当complete不完整时，它应该等待complete (而不是忽略)，如果complete是完整的，那么应该处理Observable中的项。适用于我的代码： myCompletable.andThen(m
浏览 10提问于2019-09-04得票数 0
我是Rxjs的新手，正在尝试确定这是否是一种知道Rxjs对象的所有观察者是否都完成了对.next的响应的方法。，当Auth对象调用this.authSubject$.next(evt)时，主题上活动的订阅似乎是异步处理的。(我不确定这是否完全正确，但它似乎是随机的，事情完成的顺序)。也就是说，notify方法将立即返回，而无需等待所有订阅者处理该
浏览 0提问于2021-01-17得票数 0
我想在管理状态的单例类中创建一个可观察的(即，它存储一个auth令牌)。我希望我的android应用程序/活动订阅一个可观察的，它将在每次状态更新时发出一个更新。我该怎么做？我看到的所有示例都显示了如何创建一个可观察到的自包含的可立即完成或在订阅后完成的内容。
谢谢你的帮忙!
浏览 0提问于2015-11-17得票数 2
回答已采纳
我是ReactX JS的初学者。下面是与站点中的超时相关的示例代码。我不明白现场的解释。有人能用简单的语言和逻辑来解释吗。主要关注的问题是：
Rx.Observale的含义是什么？
浏览 0提问于2018-09-11得票数 1
回答已采纳
2回答
如何等待功能和订阅在角8完成？
、、、、
我想等待一个函数完成，然后再执行它旁边的函数。我有一个名为getData()的函数，其中发生http调用，它返回一个可观察的。我们订阅的第二个函数checkDuplicate()是getData()。我们有第三个函数叫做()，在其中我们调用了checkDuplicate()函数，一旦checkDuplicate()函数完
浏览 2提问于2020-07-28得票数 8
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
