Angularfire2 snapshotchanges 订阅管道问题

Question

我正在使用@angular/fire，我刚刚为数据库设置了 snapshotChanges()，现在我尝试订阅它以保持更新。

    return this.db.list<Plan>(this.BASE_PATH).snapshotChanges().subscribe(
      item => {
        return item.map(a => {
            var p = new Plan;
            p.key = a.payload.key;
            p.name = a.payload.child(this.NAME).val();
            p.descripton = a.payload.child(this.DESCRIPTON).val();
            p.isPublic = a.payload.child(this.ISPUBLIC).val() == 'false' ? false : true;

            return p;
        })
      }
    );

但这确实会导致async 管道出现问题并给我一个错误：

ERROR Error: InvalidPipeArgument: '[object Object]' for pipe 'AsyncPipe'
    at invalidPipeArgumentError (common.js:3981)
    at 

错误实际上更长，但只是为了向您展示。

也许你有什么想法

Answer 1

您应该使用.pipe 方法和map 运算符，而不是subscribe。如前所述，您不能在订阅中使用async 模板管道：

return this.db.list<Plan>(this.BASE_PATH).snapshotChanges().pipe(
  map((items) => items.map(a => {
    const p = new Plan;
    p.key = a.payload.key;
    p.name = a.payload.child(this.NAME).val();
    p.descripton = a.payload.child(this.DESCRIPTON).val();
    p.isPublic = a.payload.child(this.ISPUBLIC).val() == 'false' ? false : true;

    return p;
  }))
);

Answer 2

您是否在模板中使用过异步管道？如果是这样，您不需要订阅 ts 类上的 snapshotChanges() 。 asyncPipe 会做到这一点