如何等待具有promise的可观察对象的每个值
等待具有promise的可观察对象的每个值可以通过以下步骤实现：
- 首先，确保你已经引入了RxJS库，因为RxJS是一个功能强大的库，用于处理可观察对象和promise。
- 创建一个可观察对象，该对象会发出promise。你可以使用RxJS的
from操作符将promise转换为可观察对象。 - 创建一个可观察对象，该对象会发出promise。你可以使用RxJS的
from操作符将promise转换为可观察对象。 - 使用
concatMap操作符来订阅可观察对象并等待每个值的解析。 - 使用
concatMap操作符来订阅可观察对象并等待每个值的解析。 concatMap操作符会按顺序订阅每个值，并等待每个promise解析完成后再订阅下一个值。- 在订阅的回调函数中，你可以处理每个值。如果有错误发生，可以在错误回调函数中进行处理。当可观察对象完成时，可以在完成回调函数中执行一些操作。
这样，你就可以等待具有promise的可观察对象的每个值了。
推荐的腾讯云相关产品：腾讯云函数（云函数是一种无服务器的计算服务，可以让你在云端运行代码而无需搭建和管理服务器。它可以与其他腾讯云产品无缝集成，提供弹性、高可用的计算能力。）。
腾讯云函数产品介绍链接地址：https://cloud.tencent.com/product/scf
相关·内容
2回答
假设我有这样一个观察点： const obs = new Observable((observer) => { observer.next(0.75); observer.complete();
}); 我如何等待每个值都有一个promise？下面的代码将只返回最后一个值(调用complete()之前的</em
浏览 25提问于2019-03-06得票数 1
回答已采纳
我需要为produtosConfirmadosAnuncio数组的每个元素发出http请求。
我正在尝试使用for()，但有时这不起作用，我的浏览器停止工作(我正在使用for中的两个元素进行测试)。也许等待第一个申请响应后再继续？
浏览 1提问于2019-01-28得票数 1
在学习RxJS的同时，我在想：例如，需要判断是否有Ajax请求挂起响应？就像和一起等待。
浏览 4提问于2013-04-23得票数 0
回答已采纳
我正在将异步方法应用于由observalbe发出的每个值。我希望此异步方法仅在前一个值的异步方法完成后才应用于下一个发出的值。下面是一个简短的示例： return new Promise(resolve => setTimeoutconsole.log(`starting to use $
浏览 2提问于2021-04-22得票数 1
我有一个函数，它接受一个对象，其中每个道具都是一个promise。它等待所有promise完成，然后返回一个具有相同属性但现在已解析的值的新对象。// TODO: fix the types on this
function promise_
浏览 79提问于2018-02-23得票数 6
回答已采纳
1回答
我有一个返回允诺的方法，并在循环中使用异步/等待概念。async getFilteredGuaranteesByPermissions(): Promise<GuaranteesMetaData[]> { return _.groupBy(guarantees, 'category');
返回布尔值我试过使用reduce，
浏览 0提问于2019-10-07得票数 3
回答已采纳
我想从一个可观察对象返回一个布尔值，但是返回行在订阅之前执行。我怎么做才能返回布尔值？this.isLow$.next(isLow); ); }
我看了这个，它没有回答我的问题如果我这样做了，isLowResolution将不再返回布尔值，且我将返回and错误
浏览 1提问于2021-05-09得票数 0
1回答
在这种情况下，我需要等待可观察对象开始发出值，然后才能执行后续代码。到目前为止，我得到的最接近的是这样的： async ensureContentLoaded() {
if (!我想让可观察对象“阻塞”，直到它开始发送值。注意，this.getContent()返回一个promise；尽管它可以很容易地返回一个observable，如果这有什么不同的话。另外，我知道this.content引用了
浏览 14提问于2019-02-22得票数 0
我正在使用Angular 2，我想知道是否有人可以解释一种情况，在这种情况下，转换和遵守承诺是有益的？我知道promises和Observable之间的区别。同样，我很好奇toPromise()操作符在哪种情况下会派上用场。
谢谢:)
浏览 1提问于2016-06-04得票数 4
3回答
如果我承诺同步运行，我希望他们两人如何完成？await不是只对一个承诺起作用吗？async function testing() { setTimeout(() => resolve("one"), 1000) setTimeout(
浏览 3提问于2020-12-06得票数 2
回答已采纳
2回答
我有一个从HTTP请求返回promise的函数： return this.service //catchError(() => of(null)) .toPromise();我想知道调用是否失败了(在本例中我没有任何令牌)，但是promise但是，如果我使用的是catchError(()
浏览 1提问于2021-04-22得票数 0
让我解释一下：如果他们成功了，应该会回来的它会抛出以下内容:未处理的拒绝(TypeError)：(中间值)不可迭代
我可以让它成为const calls = await.Promise.all(promises)，然后像calls[0]一样使用它，但是它还有其他的可能吗？
浏览 3提问于2021-11-03得票数 1
回答已采纳
为什么不能将promise转换为observable，然后在withLatestFrom中使用它。我不清楚，为什么这个问题不能解决。
浏览 26提问于2020-12-02得票数 2
回答已采纳
我有一个可等待的对象，它不是Task (例如，安装了RX的IObservable<T> )。我想创建一个Task，如果提供的CancellationToken被取消，它将被取消，否则将返回可等待对象的结果。ConfigureAwait(false); return obsTask.Result;使用这种方法，
浏览 0提问于2015-10-19得票数 4
我有一个返回值的方法，我将返回值赋值给一个变量。函数返回适当的值，但变量没有与返回值一起设置。但是，如果在函数中设置this.size，就会得到适当的值。我从许多函数调用this.searchData函数，所以我不能这样做(在本例中，我将不得不使用多个if语句)，因此有任何方法从函数中获取返回值。我以为用timeout还有别的办法吗？
浏览 5提问于2017-10-24得票数 1
回答已采纳
2回答
我使用这个问题作为起点：我的目标是只发送一个请求，并将后续请求推迟到正在运行的请求完成。完成请求后，应发出最后一个挂起事件(就像debounceTime中的情况一样)
以下代码片段中的example函数使用链接的SO问题中的方法。这将发送对所有输入值的请求。workaround函数使用存储在“流”之外的promise来阻塞和等待
浏览 2提问于2016-11-14得票数 9
我有一个观察者是这样的。我需要每个处理这个特定事件的“处理程序”来处理它，并阻塞它，直到它返回。然后处理下一个事件。
我在上面的代码中发现的是，它只是在没有等待的情况下调用事件，而我的处理程序正在踩自己的脚。我已经读了相当多的帖子，但我真的不知道该怎么做。大多数人都在谈论让观察者变得可等待。但那不是我需要的，不是吗？看起来我需要的</em
浏览 16提问于2017-07-04得票数 3
回答已采纳
我有一个可完成的和可观察的，可以发射项目的。我必须将它们组合在一起。某种Observable.combineLatest，但具有可完备性和可观察性。所以逻辑是:如果Observable首先发出项，当complete不完整时，它应该等待complete (而不是忽略)，如果complete是完整的，那么应该处理Observable中的项。适用于我的代码： myCompletable.andThen(m
浏览 10提问于2019-09-04得票数 0
3回答
我有一个这样的对象数组：results = [ {id: 3, test: physics, candidates:[ {cid: 1},{cid: 6},{cid: 7}]}因此，我需要在数组中循环，然后为每个候选对象调用一个然而，由于循环在数组中，不等待<em
浏览 45提问于2019-08-20得票数 3
2回答
因为Widget和LoggingWidget中的LoggingWidget方法都是同步的，所以在继续之前，每个方法都试图获取Widget上的锁。
我运行了上面的代码来观察内部锁。上面的引号似乎意味着线程在Widget对象上获得了一个内在锁，但我观察到的是线程在LoggingWidget上获得了一个锁。我不知道如何核实收购数量，所以无法观察到这一点。这本书是交替使用LoggingWidget/Widget<e
浏览 2提问于2015-01-12得票数 5
回答已采纳
云服务器
ICP备案
云直播
对象存储
腾讯会议
腾讯云开发者
