代码之家 › 专栏 › 技术社区 › user3024827

Angularfire rxjs多个订阅

subscription angularfire2 rxjs firebase angular

user3024827 · 技术社区 · 8 年前

我有一个angularfire函数,它可以查询Firestore中有许多可能的集合的集合。

我循环遍历包含搜索查询端点的列表,然后调用查询firebase并返回集合的搜索函数。我觉得这不是RXJS的正确使用。

当前,该循环在每个循环上订阅一个新的firebase观察器。我觉得这不是最好的做法,可以用更好的方式来做。

有没有办法创建一个订阅,但仍然传递所有下载的数据?

for (let item of list) {
    searchMap('enpoint')
      .subscribe((data) => {
        this.skillResults = this.skillResults.concat(data);
      })
  }
}

searchMap(endpoint) {
    return return this.angularfire.collection('bucket/' + endpoint).valueChanges()
}

1 回复 | 直到 8 年前

martin 8 年前

你可以使用 forkJoin 或 zip 为此:

const observables = list.map(item => searchMap('enpoint'));

Observable.forkJoin(observables).subscribe(...)

然而 分叉连接 运算符要求完成所有源观测值,这可能与 valueChanges() 所以你可以用 take(1) 。

const observables = list.map(item => searchMap('enpoint').take(1));

或者您可以使用 拉链 如果您希望源可观察对象发出相同数量的项目:

Observable.zip(...observables).take(1).subscribe(...)

也许还可以看看 combineLatest 但这取决于你想做什么。

推荐文章

Ole · 在使用新的Angular Resource API时取消搜索术语?

1 年前

koque · 为什么我的RxJs主题没有按预期工作?

1 年前

Raphaël VO · 不使用Observable的初始值

1 年前

xarielah · 从app.config.ts调用时,BehaviorSubject不会更新

1 年前

Lenni · 返回信号并在Angular中订阅它

1 年前

dman · 在Angular单元测试中似乎无法模拟行为主体

1 年前

Nevyan Dimitrov Neykov · 效果内部的角度信号()

1 年前

Ð¤ÐµÐ´Ñ Ð Ð°Ð²ÑÐµÐµÐ² · 如何在react-js中使用Date()在后台增加变量?

1 年前

Ryley38 · 如何跳过流的第一个值,除非它是RxJS的复制粘贴?

1 年前

techwestcoastsfosea · Angular 18-RxJS:Subscribe已弃用[重复]

1 年前