combineLatest不适用于promises
combineLatest是一个用于合并多个Observable的操作符，它将多个Observable发出的最新值进行合并，并生成一个新的Observable。然而，combineLatest不适用于promises。
Promises是一种用于处理异步操作的对象，它代表了一个可能尚未完成的值。与Observable不同，Promise只能发出一个值，并且在完成后不会再发出其他值。因此，combineLatest无法直接应用于promises，因为它需要多个Observable来合并它们的值。
如果想要合并多个promises的值，可以使用Promise.all方法。Promise.all接受一个promise数组，并在所有的promise都完成后返回一个新的promise，该promise的值是一个包含所有promise结果的数组。
在腾讯云的云计算服务中，与promises相关的产品是云函数（Serverless Cloud Function）。云函数是一种无需管理服务器即可运行代码的计算服务，它支持使用JavaScript编写函数，并可以与其他腾讯云产品进行集成。您可以使用云函数来处理异步操作，包括处理promises。
更多关于腾讯云函数的信息，请访问腾讯云函数的官方文档：云函数产品介绍。
相关·内容
这是我的代码，我从一个空数组开始，希望调用一个服务来处理填充的数组。我使用两个对服务的调用填充数组，后者调用一个API来接收要插入到数组中的元素。
我不知道如何让最后一个服务调用等待，直到数组被填充后才能执行命令。我认为，我有两个独立的服务调用要等待，而且它们都有forEach循环，这使得这个问题变得更加困难。有什么想法吗？
const subscribers: ISubscriber[] = [];
this.selectedChildren.forEach(child => {
this.serviceA.getSubscribers(child.id).subscribe
浏览 0提问于2019-03-21得票数 2
回答已采纳
2回答
forkjoin不返回任何结果
、、、、
我正在使用forkJoin来组合两个firebase请求的结果
两个请求都完成并记录在控制台中，但是forkJoin本身的map函数不会触发，因此不会将结果返回给应用程序
public initGroup(groupname, username){
console.log(groupname, username)//This logs
return Observable.forkJoin([
this.getGroup(groupname, username),
this.groupMembers(username, groupname),
])
浏览 22提问于2017-07-06得票数 2
回答已采纳
我使用角5和angularfire2与Firebase一起工作。我有一个字符串数组，它将路径表示为火基。我现在要做的是：
const pathList: string[] = ['path1', 'path2', 'path3'];
const observableList = [];
pathList.map((location: string[]) => {
observableList.push(this.db.object(`path_to_something/${location}).valueChanges())
浏览 0提问于2018-01-25得票数 2
回答已采纳
1回答
我正在尝试从我拥有的数组向api发出put请求。post需要一个对象，而我有一个对象数组。我所做的是一个循环，迭代对象数组的长度，将方法调用到我的服务中。问题是，只有第一个有效，其余的都不起作用。我是否应该像return promise这样的东西，然后递归地调用它？
下面我让我的方法调用api：
onUpdate() {
for (var i = 0; i < this.conditionsToUpdate.length; i++) {
this.ruleService.updateConditionsFromRule(this.rule.id, this.condition
浏览 0提问于2017-05-23得票数 0
3回答
不同方法的角度组合数据
、、、
我有来自三个不同服务的数据，我想将来自所有服务的数据合并成一个方法。
this.data1 = this.activity1Service.getAllMonth();
this.data2 = this.activity2Service.getAllMonth();
this.data3 = this.activity3Service.getAllMonth();
this.alldata = concat (this.data1,this.data2,this.data3);
作为一个可以观察到的召唤
GetAllData(): Observable<Data[]>{
浏览 2提问于2019-12-02得票数 2
回答已采纳
我自己解释一下：
我想要做的是对其中一个库(async或bluebird)使用async/await。
我不明白为什么这样做效果很好：
const promises = Promise.map (someArray, async item => {
const result = await getSomething(item);
return {...item, ...result}
});
const promisesResults = await Promise.all(promises);
但是和async.map一样，它不
浏览 0提问于2019-03-07得票数 0
我有两个FLowable对象。当所有代码都被消耗时，我需要执行一些代码。此外，我需要执行代码时，任何流动更新。我不需要执行任何映射函数(不需要它们)。
我试过使用下面的代码
我认为这样做是非常错误的。
Flowable<User> user = mDataRepo.getUser();
Flowable<Goal> goal = mDataRepo.getGoal();
Disposable userDisposable = user
.subscribeOn(Schedulers.io())
.observeOn(AndroidSche
浏览 1提问于2019-02-04得票数 0
我正在尝试创建一个守卫，以验证用户是否被允许导航到基于总线逻辑的路线。 但是我得到的异步函数或方法的返回类型必须是全局Promise type.ts async canActivate(
next: ActivatedRouteSnapshot,
state: RouterStateSnapshot): Observable<boolean | UrlTree> | Promise<boolean | UrlTree> | boolean | UrlTree {
const idCliente = +next.paramMap.get('id&#
浏览 203提问于2020-08-23得票数 0
回答已采纳
有相当于Promise.all的吗？
let prom1 = doA(); // some promise
let prom2 = doB(); // another promise
// wait for both promises to complete.
Promise.all([prom1, prom2], values => {
// do something;
});
不能把它从文档中拼凑在一起，各种文章建议ForkJoin，但不能让它工作.
let behaviour1 = new BehaviourSubject(0);
let behaviour2 = ne
浏览 3提问于2016-03-07得票数 2
回答已采纳
2回答
我正在开发一个从Jira中提取数据的工具。我可以找到很多使用前一次调用中的数据链接多个http调用的示例。但我偶然发现的是，如何等待所有内部调用解析并处理数据，然后才解析外部调用。 这里发生的事情是，方法this.developmentService.getData(this.filter)不等待内部this.developmentService.getStoriesForEpic(epic.key)中每个史诗故事的计数完成，这是有问题的，因为在此之后，我需要基于这些计数应用额外的过滤器。 updateChart() {
this.loading = true;
if (th
浏览 21提问于2019-06-03得票数 0
在socket.io客户端javascript中，我是这样连接的
var socket = new io();
然后我将数据发送到服务器，如下所示
socket.emit('start', data);
但我想尽快将数据发送到服务器，并承诺已收到数据。我该怎么做呢？我希望有像这样的东西
var socket = new io(null, data, function(data) {
// data was received on server and server responded with complete
// data is 'ok'
}
浏览 2提问于2017-09-16得票数 0
6回答
我很难弄到一些可观察的东西。我似乎没办法把两个可观察到的东西放在一起。他们自己工作很好，但我需要这两种价值观。
db.glass.subscribe( ( glass: GlassData[] ): void => {
console.log( glass ); // This prints
});
db.cassette_designs.subscribe( ( cassettes: CassetteData[] ): void => {
console.log( cassettes ): // This prints
});
我不太熟悉可观察到的东西，第一件事就是在另
浏览 9提问于2016-07-14得票数 9
回答已采纳
1回答
合并多个可观测值并返回一个
、、、、
我有一个函数，它应该返回一个可观察到的Conversations列表。为此，我必须从另一个表Participants中获取用户会话I，并将这些会话I逐一组合起来。
public getConversations(user_id: string): Observable<Conversation[]> {
return this.firebase
.collection<Participant>(this.PARTICIPANTS_COLLECTION, ref =>
ref.where('user_id', &#
浏览 0提问于2018-07-23得票数 2
回答已采纳
我不知道在哪种情况下使用zip，在哪种情况下使用combineLatest。有人能帮我吗？
浏览 19提问于2021-10-27得票数 0
2回答
我需要捕捉事件，同时用RxJS按左右鼠标按钮。更准确地说，您需要用鼠标右键和左键捕捉鼠标事件，最大差值为300 ms。
浏览 2提问于2019-03-12得票数 1
回答已采纳
1回答
组合用于准备数据的多个条件观测值
、、、、
我有两个stores，我需要准备合并的数据
获得所有部门的departments)To (为ex 50获取所有用户(例如：1000用户)
我想合并数据和准备最终数据。备注：部门将要求所有用户都被加载(这可能需要一段时间)，而且不经意地，users不能单独做任何事情，因为他们需要department数据来准备最终结果。
这是给department的
this.store.select(getUserInfo).subscribe((info) => {
this.store.select(getAllDepts).subscribe((depts) =>
浏览 1提问于2020-10-23得票数 0
回答已采纳
我使用的是azure-function-express节点模块。文档提到了{*segments}的使用，但没有提供太多的上下文。
下面是我的function.json文件的外观：
{
"disabled": false,
"bindings": [
{
"authLevel": "anonymous",
"type": "httpTrigger",
"direction": "in",
"name
浏览 2提问于2018-10-04得票数 0
1回答
如何理解复杂的打字通用类型？
、、、、
我在检查RxJS api文档。在理解上面写的奇怪语法时，我总是会遇到一些问题，如下所示：
combineLatest<O extends ObservableInput<any>, R>(...observables: (O | ((...values: ObservedValueOf<O>[]) => R) | SchedulerLike)[]): Observable<R>
我想要理解这种语法，并进一步自己编写它。
因此，如果有人解释上面的例子中发生了什么，这将是很有帮助的。
浏览 0提问于2019-07-16得票数 9
回答已采纳
这是我的密码
getPostInfo(id: string) {
const Post = this.afStore.collection(`services/${id}`)
.valueChanges()
.pipe(
switchMap(services => {
const res = services
.map((service: Service) => {
return this.afStore.doc<UserMode
浏览 4提问于2020-10-05得票数 0
回答已采纳
我有以下练习：
const { promisify } = require('util')
const print = (err, contents) => {
if (err) console.error(err)
else console.log(contents)
}
const opA = (cb) => {
setTimeout(() => {
cb(null,'A')
}, 500)
}
const opB = (cb) => {
setTimeout(() => {
cb(
浏览 3提问于2021-06-08得票数 0
我已经订阅了我想要传送的数据。但不知何故，它不起作用。我知道这个错误：
属性管道不能用于“，OperatorFunction<unknown，unknown，any>”类型
这是我的代码：auth.service
authenticationState = new BehaviorSubject(false);
checkToken() {
this.storage.get(TOKEN_KEY).then(access => {
if (access) {
this.user = this.helper.decodeToken(access
浏览 3提问于2019-11-24得票数 1
回答已采纳
我使用google places自动完成和距离矩阵来输入两个位置，并打印出两个位置之间的距离。我有两个javascript es6类来分隔Google API作为服务。 我的问题是，我试图等待从距离矩阵服务获得距离的响应，然后将其记录到控制台，但当我记录它时，我得到了未知的定义。距离矩阵服务在我记录后返回响应。这一定意味着我在方法中的等待不起作用。我做错了什么？ distanceMatrix.js export default class DistanceMatrixService {
constructor(pickup, dropoff, garage){
...
浏览 11提问于2019-02-17得票数 0
回答已采纳
2回答
未调用combineLatest
、、、、
我有以下代码 我是rjxs编程的新手，所以想知道根本原因是什么。我正在尝试做一个特定的任务，首先合并所有最新的结果，然后订阅分配结果。但combineLatest似乎不能正常工作。可能的原因是什么？ const downloadUrls$: any = Array.from(event.target.files).map((file: any) => {
const fileName = ...
const path = ...
const fileRef = ....
const task: any = ...
return task.snapshotChang
浏览 22提问于2020-04-22得票数 0
1回答
我正在尝试将我的代码从rxjs 5.x重构到rxjs 6和Angular 6。我有一个本质上触发搜索的代码：
startAt = new Subject();
endAt = new Subject();
startobs = this.startAt.asObservable();
endobs = this.endAt.asObservable();
constructor() {}
ngOnInit(){
var that = this;
Observable.combineLatest(this.startobs, this.endob
浏览 19提问于2018-08-01得票数 1
回答已采纳
1回答
我正在寻找一种使流组合起来的方法--注意:这是我问题的最简单的形式，实际上我正在组合8种不同的流--有些是相互交织的，有些是异步的，等等:(
import { BehaviorSubject, map, combineLatest } from 'rxjs';
const $A = new BehaviorSubject(1)
const $B = $A.pipe(map(val => `$B : ${val}`))
const $C = $A.pipe(map(val => `$C : ${val}`))
// prints out:
// (1) [1, &
浏览 8提问于2022-10-29得票数 1
回答已采纳
我想创建一个队列，在这个队列中，我总是并行执行两个httpRequests。当一个请求完成时，下一个请求应该启动，以便始终有两个请求并行运行。我希望合并结果，并在所有请求完成后将其作为一个整体返回。
我的第一个尝试是创建一个主题(队列)，在那里我用queue.next(url)传递url。考试结束后，我立即完成了这门课.我使用mergeMap将执行限制为一次只能执行两个请求(queueObservable)。
我订阅了queueObservable并将响应添加到一个数组(列表)中。然后，我等待queueObservable的承诺，它应该在可观察对象完成时解决。
但实际情况是，promise甚至
浏览 2提问于2019-08-22得票数 1
在这个演示应用程序中，我们有以下结构：
项目列表(页面加载时加载)每一篇文章都有一个名为detail的嵌套对象，延迟加载
单击项目将加载其详细信息。
但我面临的问题是导出按钮(在本例中是模拟的)。最初的导出不包含文章的详细信息。如果我再导出几秒钟后，细节也包括在内。
文章服务中的延迟模拟了http调用中的一些延迟。解决这个问题的正确方法是什么？我知道这在添加某些延迟()时是有效的，但我不喜欢这个解决方案。
浏览 1提问于2021-02-18得票数 0
回答已采纳
我正在使用RxJS 6，我的代码中有两个可观察到的
import { combineLatest } from 'rxjs/operators';
loading$: Observable<boolean>;
loaded$: Observable<boolean>;
可观察到的不是来自http请求，而是来自store
我需要根据这个逻辑将序列组合/转换为一个可观察的值：
如果序列true、true或false -需要返回新的可观测true，则需要返回false。
我试图使用combineLatest来实现这个目标：
combineLatest(
浏览 0提问于2018-05-15得票数 7
回答已采纳
8回答
我最近更新了从角5到角度6。
我收到警告combineLatest is deprecated: resultSelector no longer supported, pipe to map instead。Rxjs版本为6.1.0，tslint为5.10.0，角CLI为6.0.0，类型为2.7.2。我就是这样用的：
const a$ = combineLatest(
this.aStore.select(b.getAuth),
this.cStore.select(b.getUrl),
(auth, url) => ({auth, url}),
);
我也试过这样做：
e
浏览 0提问于2018-05-10得票数 33
回答已采纳
2回答
我将首先向您展示工作代码：
<input [formControl]="search"
[typeahead]="suggestions"
typeaheadOptionField="name"
(typeaheadOnSelect)="onSelectedDriver($event)">
ngOnInit(){
public autocompleteValue() {
this.search.valueChanges.subscribe(
浏览 3提问于2021-10-27得票数 0
所以withLatestFrom非常接近我需要的东西，但是它有一个奇怪的行为。仅当"master“在"slave”之后发出时，它才发出一个值。如下大理石图所示： --1----2-------2---- (source)
----a-------b------- (other1)
-------2a------2b-- 我需要一个运算符，它的行为如下： --1------2-------2---- (source)
----a---------b------- (other1)
----1a---2a------2b-- 还有这个： ------1------2-------
浏览 20提问于2020-11-23得票数 2
3回答
我在代码中使用组合参数，并且传递了6个以上的参数。我们刚刚从5.x升级到6.0，这会导致编译错误。这是它的示例代码。
错误：
类型'OperatorFunction<string，number，number，string，number，string>‘的参数不能分配给'OperatorFunction’类型的参数。输入'string，number，number，string，number，number，number‘不能分配给键入'string[]’。属性'pop‘的类型是不兼容的。类型'() =>字符串\N‘不能分配给键入
浏览 0提问于2019-05-14得票数 0
2回答
我在找我的用户正在听的所有音乐。我是这样做的
User.find().exec((err, users) => {
users.forEach((user, index) => {
Musics.count({ idReader: user._id }, (err, count) => {
result.push({ mail: user.mail, count: count });
if (index >= users.length - 1) {
return re
浏览 0提问于2018-03-06得票数 1
回答已采纳
在运行rxjs迁移工具之后，使用
迁移-p src/tsconfig.app.json
我现在得到了一个衬里错误：
不建议使用combineLatest :不推荐使用静态combineLatest。
在运行迁移命令之前，下面是我的代码：
this.store.combineLatest(
this.store.select(lang.getCurrent),
this.store.select(lang.getCurrentLocale)
).subscribe(([state, currentLang, locale]) => {
浏览 0提问于2018-05-10得票数 93
回答已采纳
1回答
我有一个问题要过滤一个可观测的数组，在我的例子中是resources$ (一个可观测的，包含所有的‘资源’作为JSON)，我还有另一个可观察的名为usedResources$，我想要实现的只是从这两个变量的unusedResources$ (资源- usedResources = unusedResources)，有什么RxJS方法来实现这一点吗？
浏览 3提问于2017-06-01得票数 1
回答已采纳
下面的代码会导致使用Observable.combineLatest is not a function 5.0的RxJS：
let Observable = require('rxjs/Observable.js').Observable;
import 'rxjs/add/operator/combineLatest';
Observable
.combineLatest([player, spaceShip], (shotEvents, spaceShip) => ({
x: spaceShip ? spaceShip.x : board.
浏览 1提问于2016-03-14得票数 35
回答已采纳
2回答
我在Rxswift中有一系列的布尔观测值。 let rxBoolObservableArray: [Observable<Bool>] = [Observable<Bool>]() 现在，如果有任何元素为false，如何获取？
浏览 9提问于2019-02-05得票数 0
回答已采纳
2回答
我有一个使用Firestore的简单的React。我在Firestore中有一份文档：
{
date: November 20, 2022 at 11:24:44 AM UTC+1,
description: "...",
title: "Dummy title",
type: "student",
userRef: /users/0AjB4yFFcIS6VMQMi7rUnF3eJXk2
}
现在我有了一个自定义钩子，它获取数据：
export const useAnnouncements = () => {
const [anno
浏览 3提问于2022-11-20得票数 0
回答已采纳
2回答
把期望值的两部分都承诺
、、、、
问题：
在Protractor中，expect()被修补为隐式理解承诺，从而实现了速记断言风格。例如：
expect(elm.getText()).toEqual("expected text");
这里的elm.getText()不需要使用then()显式解析，在检查期望之前，它将由Protractor隐式解析。
但是，如果“相等”部分也是一种承诺，该怎么办？例如，来自另一个元素的文本。在这种情况下，我们必须显式地解决第二部分：
elm2.getText().then(function (text2) {
expect(elm1.getText()).toEqual(
浏览 3提问于2016-07-21得票数 2
回答已采纳
在combineLatest之后，我的可流动链无法继续运行。最后，我尝试在一个单独的类中重现该行为。我发现有一点令人不安：
public static void main(String[] args) throws InterruptedException {
test();
test();
Thread.sleep(10000);
}
private static void test() {
System.out.println("before");
Flowable<Integer> fa = Flowable.<
浏览 0提问于2018-01-28得票数 2
1回答
在我的代码中，我需要使用timer(500)添加延迟。但问题是它返回部分数据。它返回两个字段，而实际数据有17个字段。我已经附上了我的密码。请看一下。谢谢
返回值：
['booking_display_id', 'edit']
期望值：
['booking_display_id', 'bookingstatus', 'b_contactname', 'member', 'b_emailaddress', 'b_mobilenumber', 'startda
浏览 1提问于2022-06-22得票数 1
我已经使用withLatestFrom编写了一个Observable this.scopes$ = service.getScopes(); 此外，我还编写了另一个Observable @Component(...)
export class MyComponent {
@Input('app')
public set app(app: ApplicationUser) {
this._app = app;
this.inputApp$.next({...this._app});
};
constructor(
浏览 15提问于2019-08-28得票数 1
1回答
我使用angularjs已经2个月了，但从来没有遇到过这样的问题，所以我想和大家分享一下，并得到一些好的建议。在这里，我尝试应用ul/nav-group元素动态值。一切正常意味着，如果我在浏览器上看到开发人员工具，它会得到值和所有东西，但不是+/-号。我在google上搜索，它说它是在DOM创建之后加载的，所以没有显示出来。但是没有朋友告诉你解决这个问题的方法。考虑我的代码：
<nav:group ng-repeat="parentChild in parentChildList" title="{{parentChild.filterText}}">
浏览 3提问于2015-02-16得票数 0
2回答
Service.ts文件
第5版代码：
return this.connectionListStoreService.connections$.pipe(
combineLatest(this.isLoadPending$),
filter(([connections, isPending]) => !isPending),
map(([connections]) => connections),
combineLatest(
this.adapterStoreService.adapters$,
this.applicationsStoreServ
浏览 3提问于2020-11-13得票数 2
在非异步代码中，我执行以下操作： const x = [
...(isY ? [Y]: []),
...(isZ ? [Z] : [])
]; 当isY和isZ都是Observables<boolean>，而x是Observable<Object[]>时，你如何优雅地编写这种结构。 我可以使用所有类型的映射来做到这一点，但没有一种映射看起来是干净或优雅的。
浏览 22提问于2019-04-10得票数 1
回答已采纳
这是我第一次涉足RxJS，所以如果有更好的解决方案，我会全力支持。我的目标是收集相关对象并在代码中连接它们(本质上是sql左连接)。这源于我使用一个Angular In Memory API对象作为DB，直到它建立起来。 当我组合Plans、Specieses、Codebook、UpstreamModalities和TissueProcessions时，这段代码可以正常工作。当我包含Probe、Imaging和Analysises流时，我会遇到要读取的错误blob，这让我很头疼。基本上，array.map函数中的每一行都会抛出TS2349错误，即使是在添加其余三个源之前有效的那些错误也是如此
浏览 35提问于2019-07-25得票数 9
回答已采纳
1回答
如何用combineLatest组合可观测数据。未定义combineLatest
我使用的是angular js 7。我想要获取两个查询字符串参数，但是当我编写obserable.combinelaste([])时，它会给出错误。
import { Component, OnInit } from '@angular/core';
import { ActivatedRoute } from '@angular/router';
import { Observable, of, observable } from 'rxjs'
import {
浏览 1提问于2019-04-20得票数 0
我试图在我的网站中添加一个InstantSearch函数。我使用的是角12.2，使用的是具有索引"book-data“的防火数据库。我在搜索组件中使用以下代码：
import { Component, OnInit } from '@angular/core';
import { AngularFirestore } from 'angularfire2/firestore';
import { Subject } from 'rxjs';
import { Observable } from 'rxjs';
@Comp
浏览 4提问于2022-04-29得票数 0
3回答
是否有可能等待订阅的角？
、、、
我想展示这样的帖子列表：
为了显示哪个帖子是用户最喜欢的，我需要来自mongodb数据库中的两个不同集合的数据。当前，我的post-list.component.ts文件的ngOnInit如下所示：
ngOnInit() {
this.isLoading = true;
this.postsService.getPosts(this.postsPerPage, this.currentPage);
this.favoritesService.getFavorites(this.postsPerPage, this.currentPage);
this.use
浏览 1提问于2021-12-15得票数 0
回答已采纳
我在处理链式操作列表中的一个操作时遇到了麻烦。我正在尝试使用反应性Cocoa来提供一个位置流，同时用户登录并授予对位置服务的访问权限。
总的来说，我对反应性Cocoa和函数式反应性编程还很陌生，但我到目前为止所得到的是这样的：
@weakify(self);
// signal of BOOL
RACSignal *loggedInSignal = [[self loggedInSignal] distinctUntilChanged];
// signal of CLAuthorizationStatus
RACSignal *currentStateSignal = [[self cu
浏览 2提问于2015-07-08得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
