firebase-如何使用rxjs划为拼写 - 最后的和平

Question

我看到了这篇文章： Cloud Firestore-如何使用RXJS

这正是我需要的，但我不明白如何重现

import { UsersService } from '../../../shared/services/users.service';

我只需要理解此服务中的内容，因为我不能像getUsers（）和loadMoredata（）。我正在学习有关AngularFire的新模块化方法，上面的答案是我需要理解的方法才能正确实施分页。

到目前为止，我所做的事情：

import {
  collection,
  collectionData,
  Firestore,
  limit,
  orderBy,
  query,
  startAfter
} from "@angular/fire/firestore";


querySnapshot:any;
lastInResponse:any;


  constructor( private stringEmitted: StringBridgeService, private firestore: Firestore ) {
  }

  ngOnInit(): void {
    this.stringEmitted.stringChanged(this.actualTitle);
    this.loadCustomers('customers', 'name', 5)
  }


  loadCustomers(collectionName:string, order:string, max:number) {
    return collectionData(query(collection(this.firestore, collectionName), orderBy(order), limit(max))).subscribe(
      response => {
        // @ts-ignore
        this.lastInResponse = response[response.length - 1];
        this.querySnapshot = response;
      }
    );
  }

  loadMore(data:object) {
    return collectionData(query(collection(this.firestore, 'customers'), orderBy('name'), limit(5), startAfter(data))).subscribe(
      response => {
        // @ts-ignore
        this.lastInResponse = response[response.length - 1];
        this.querySnapshot = this.querySnapshot.concat(response);
      }
    );
  }

  myTest() {
    console.log(this.lastInResponse);
  }

我只有这个代码错误firbaseError：function startafter（）带有无效数据的函数。函数myTest（）将从最后一个客户写入控制台的正确数据，但仍然出现错误。

正确的数据类型是什么？我该如何转换？

任何帮助将不胜感激！谢谢！

Answer 1

我设法找到了解决方案！

import {
  collection,
  collectionData,
  Firestore,
  limit,
  orderBy,
  query,
  startAfter
} from "@angular/fire/firestore";


querySnapshot:any;
lastInResponse:any;


  constructor( private stringEmitted: StringBridgeService, private firestore: Firestore ) {
  }

  ngOnInit(): void {
    this.stringEmitted.stringChanged(this.actualTitle);
    this.loadCustomers('customers', 'name', 5)
  }


  loadCustomers(collectionName:string, order:string, max:number) {
    return collectionData(query(collection(this.firestore, collectionName), orderBy(order), limit(max))).subscribe(
      response => {
        this.lastInResponse = response[response.length - 1];
        this.querySnapshot = response;
      }
    );
  }

  loadMore(data:any) {
    if(this.lastInResponse){
      return collectionData(query(collection(this.firestore, 'customers'), orderBy('name'), limit(3), startAfter(data['name']))).subscribe(
        response => {
          this.lastInResponse = response[response.length - 1];
          this.querySnapshot = this.querySnapshot.concat(response);
          // this.querySnapshot = response;
        }
      );
    }
    return null
  }

  myTest() {
    console.log(this.lastInResponse);
  }

startafter（）在我的情况下，我的列表上的姓氏要求。此处使用了True 模块化方法。

谢谢大家！