连接两个 observables 以在多个字段上进行 firestore 查询

Question

我正在尝试在我的 AngularFire 应用中使用用户搜索功能。 由于firestore不支持这些查询，我认为单独查询字段就足够了

getUsersByName(searchValue: string) {
    const firstNames = this.afs.collection<IUser>('user', ref => ref.orderBy('firstname').startAt(searchValue).endAt(searchValue+'\uf8ff')).valueChanges({ idField: 'id' });
    const lastNames = this.afs.collection<IUser>('user', ref => ref.orderBy('lastname').startAt(searchValue).endAt(searchValue+'\uf8ff')).valueChanges({ idField: 'id' });
    return concat(firstNames, lastNames);
  }

这仅适用于firstNames。只有第一个 Observable 被使用。我想我不了解 concat 运算符，但根据文档，我不清楚当前针对此问题的最佳解决方案是什么。

Answer 1

你可以使用 zip 运算符

const firstNames: Observable<string>
const lastNames: Observable<string>
zip(firstNames,lastNames).subscribe(
  ([firstName,lastName]) => { console.log(firstName,lastName);}
)

如果 firstNames 和 lastNames 只发出一个项目， combineLatest([firstNames,lastNames]) 将更具可读性

了解如何使用这些运算符的好链接https://indepth.dev/posts/1114/learn-to-combine-rxjs-sequences-with-super-intuitive-interactive-diagrams

Answer 2

这仅适用于名字的原因是concat 的工作方式；在完成之前，它一次只会使用一个 observable，但 firestore observable 的寿命很长，不会完成。

您应该使用merge 而不是concat。

import { merge } from 'rxjs';

getUsersByName(searchValue: string) {
    const firstNames = this.afs.collection<IUser>('user', ref => ref.orderBy('firstname').startAt(searchValue).endAt(searchValue+'\uf8ff')).valueChanges({ idField: 'id' });
    const lastNames = this.afs.collection<IUser>('user', ref => ref.orderBy('lastname').startAt(searchValue).endAt(searchValue+'\uf8ff')).valueChanges({ idField: 'id' });
    return merge(firstNames, lastNames);
  }