更新数组后运行方法

Question

我有一个从Firebase获取数据的服务。该服务提供了一个可观察的，然后我在组件类中订阅它。当数据被加载并发送到数组时，DOM会更新新数据，但是我需要在DOM更新后再次运行一些javascript和jQuery代码，我不知道如何运行。

我的服务方式是这样的：

getSubjects() {
    return new Observable(observer => {
      this.subjectsRef.orderByChild('name').on("value", snapshot => {
        var tempArr = [];
        snapshot.forEach(function(data) {
          var subject = {
            name: data.val().name,
            imgUrl: data.val().imgUrl,
            description: data.val().description,
            teachers: data.val().teachers
          }
          tempArr.push(subject);
        });
        observer.next(tempArr);
      });
    // this.broadcastUpdate();
  });
  }

和我的组件：

export class SubjectsCmp implements AfterViewInit, OnInit, OnChanges {

  constructor(
    private _subjectsService: SubjectsService
  ) {
  }

  ngOnInit() {
    this._subjectsService.getSubjects().subscribe( subjects => this.subjects = subjects);
  }
}

我看了一些RxJS的文档，但是没有用。我想我可以按照他们给出的例子重写它：

var subscription = source.subscribe(
  function (x) {
    console.log('Next: %s', x);
  },
  function (err) {
    console.log('Error: %s', err);
  },
  function () {
    console.log('Completed');
  });

但“完成”永远不会开火。

Angular 2的onChanges observer只响应由输入事件引起的更改，因此也不起作用。基本上，我只需要在填充数组后运行一个方法，我想我遗漏了一些明显的东西？

Answer 1

方法返回Subcriber，它继承可以使用的add（）方法：

ngOnInit() {
  this._subjectsService.getSubjects()
    .subscribe( subjects => this.subjects = subjects)
    // add new subscription
    .add(() => console.log('Completed', this.subjects));
}