Observable.forkJoin()不执行

Question

我有以下代码:

//Loop: For each user ID/Role ID, get the data
userMeta.forEach((businessRole) => {
  Observable.forkJoin(
    af.database.object('/roles/'+businessRole.$value),
    af.database.object('/users/'+businessRole.$key)
  ).subscribe(
    data => {
      console.log("Data received");
      data[1].role = data[0];
      this.users.push(data[1]);
    },
    err => console.error(err)
  );

我试图订阅使用2个observable的结果forkJoin.

由于某些原因,未显示"已接收数据"消息.

我的userMeta变量在console.log中看起来很好:

怎么了？

更新:以下代码也不返回任何内容

let source = Observable.forkJoin(
        af.database.object('/roles/'+businessRole.$value),
        af.database.object('/users/'+businessRole.$key)
    );
    let subscription = source.subscribe(
      function (x) {
    console.log("GOT: " + x);
  },
  function (err) {
    console.log('Error: %s', err);
  },
  function () {
    console.log('Completed');
  });

我实际上要做的是提高以下代码的性能:

//Subscription 3: role ID to role Name
        af.database.object('/roles/'+businessRole.$value)
        .subscribe((roleData) => {
        //Subscription 4: Get user info
        af.database.object('/users/'+businessRole.$key).subscribe(user => {

Answer 1

forkJoin() 要求所有源Observable至少发出一次并完成.

以下演示按预期完成:

const source = forkJoin(
  from([1,2,3]),
  from([9,8,7,6])
).subscribe(
  x => console.log('GOT:', x),
  err => console.log('Error:', err),
  () => console.log('Completed')
);

现场演示:https://stackblitz.com/edit/rxjs-urhkni

GOT: 3,6
Completed

2019年1月:更新了RxJS 6

Answer 2

我有一个类似的问题使用Angular 2/Angularfire 2,特别是在我查询用户是否通过电子邮件存在的问题.在一种情况下,用户存在,我从Observable接收了一个对象的数组.在另一种情况下,用户不存在,我收到一个空数组.

当我使用带有resultSelector和subscribe的forkJoin时,resultSelector和subscribe函数都没有运行.但是,当我尝试

Observable.zip(
  FirebaseListObservable,
  FirebaseListObservable,
  (...results) => {
    return results.map(some code here)
  }
).subscribe(res => console.log(res));

选择器和订阅都工作.我认为这与@ martin的答案有关,其中forkJoin需要observables来完成,因为根据定义它返回最后的排放.如果一个观察者永远不会完成,我想它永远不会有最后一次发射.

也许angularfire列表observables(或你的情况下的object observable)永远不会完成,使得forkJoin的使用变得不可能.幸运的是,zip具有类似的行为并且仍然有效,不同之处在于,如果Firebase中的数据发生更改,它可以重复多次,而forkJoin只会结合最后一个响应.

就我而言,我正在寻找1)使用zip并接受我的代码可能会运行多次如果用户数据在.zip仍在运行时发生变化,2)在第一组数据返回后手动禁用zip,或者3)抛弃Angularfire并直接尝试Firebase api,使用像.once这样的东西来查看是否可以获得完成并触发forkJoin的observable.

Answer 3

我遇到了类似的问题:我正在动态创建一个observable列表,我注意到forkjoin()如果observable列表为空,则永远不会发出也不会完成,而Promise.all()使用空列表解析:

Observable.forkJoin([])
    .subscribe(() => console.log('do something here')); // This is never called

我找到的解决方法是检查列表的长度,并在它为空时不使用此运算符.

return jobList.length ? Observable.forkJoin(jobList) : Observable.of([]);

Answer 4

我遇到了同样的问题，我无法真正让forkJoin操作员工作，所以我只是使用了combineLatest，它已经起作用了！

Answer 5

只需添加observer.complete（）;

不管用：

observer.next(...)

将工作：

observer.next(...);
observer.complete();

希望能帮助到你。