订阅神秘地没有触发

Question

所以我正在使用 Angular 和 Firestore。出于某种原因，我可以在一个地方订阅可观察到的罚款，但不能在另一个地方订阅，我不知道为什么。我觉得可能是因为我曾经在某个地方订阅过它。我可以没有一个 同时运行订阅和使用 take(1) 还是什么？我没有收到任何错误，它只是停在那里。

private jobDoc: AngularFirestoreDocument<Job>;
job: Observable<Job>;


ngOnInit() {
  this.route.params.subscribe(jobId => {
    this.createJobPage().then(function(result){
      this.job.subscribe(job => {
        console.log('this works');
      });
    }.bind(this));
  });
}


// When I load the page we run this function
createJobPage() {
  return new Promise(function(resolve){
    this.getUser().then(user => {
      this.jobDoc = this.afs.doc(`accounts/${user['cid']}/jobs/jobId`);
      this.job = this.jobDoc.valueChanges();
      this.job.take(1).subscribe(job => {
        console.log('this works');
      });
      resolve();
    });
  }.bind(this));
}


// Clicking a button saves the info
saveNewJob() {
  this.getUser().then(function(user) {
    console.log('this works, and shows "this.job" is an observable', this.job);
    this.jobDoc.update({id: 1})   // If I add this line it all works
    this.job.take(1).subscribe(job => {
      console.log('this does not work'); // This doesn't work
    });
    console.log('This works');
  }.bind(this));
}

-------- 更新 --------

我认为这是一个错误。这有效：

this.jobDoc.update({id: 1})
this.job.take(1).subscribe(job => {
  console.log('this works');
});

但如果我删除 jobDoc 更新它就不起作用，像这样：

this.job.take(1).subscribe(job => {
  console.log('this works');
});

所以看来如果我想订阅这个，我需要先给jobDoc 一点刺激才能唤醒它……有人知道为什么吗？

Answer 1

也许可以尝试使用first() 而不是take(1)，取 1 发出 1 并取消订阅。

Answer 2

这真的让我很好奇，所以我去了 firebase 源文档并找到了这个 https://github.com/angular/angularfire2/blob/master/src/firestore/observable/fromRef.ts

valueChanges 是由这些函数构建的，关键部分是：

export function fromRef<R>(ref: firebase.firestore.DocumentReference | 
    firebase.firestore.Query) {
    return _fromRef<typeof ref, R>(ref).share();
}

这是一个共享的 observable，因此一旦完成，所有当前和未来的订阅者都会完成。所以最初的 take(1) 完成了它，然后任何未来的订阅者都不会从中得到任何东西，这就是重新引用它起作用的原因，因为它重新创建了共享的 observable。

Answer 3

要修复它，我只是重新设置了this.job，但我不知道为什么我需要这样做。也许是一个错误？如果有人知道，LMK

this.job = this.jobDoc.valueChanges();
this.job.take(1).subscribe(snap => {
  console.log('WORKED!');
});

Answer 4

不是bug，this.job是this.jobDoc的引用

经过进一步审查，saveNewJob() 在没有触发器的情况下添加了订阅者。

添加this.jobDoc.update 是触发器:)

saveNewJob() {
  this.getUser().then(function(user) {
    console.log('this works, and shows "this.job" is an observable', this.job);
    this.jobDoc.update({id: 1})   // If I add this line it all works
    this.job.take(1).subscribe(job => {
      console.log('this does not work'); // This doesn't work
    });
    console.log('This works');
  }.bind(this));
}