Как подписаться на источник событий один раз?

Question

// Part of service
public someEvent: EventEmitter<number> = new EventEmitter();

....

// Component
@Component({
  selector: 'some-component',
  template: `...`
})
export class SomeComponent {
  constructor(public service: Service) {
    this.service.someEvent.subscribe((x) => {
      // Do something
    });
  }
}

SomeComponent отображается в / маршрут. Когда я перехожу к другому маршруту в моем приложении и возвращаюсь снова, SomeComponent снова подпишется на событие, дважды вызвав обратный вызов. Как подписаться на событие один раз или отписаться на уничтожение компонента и подписаться снова?

// Can't subscribe after.
ngOnDestroy() {
  this.service.someEvent.unsubscribe();
}

Answer 1

Вызов subscribe возвращает экземпляр Disposable, который имеет метод dispose,

Или, если вы используете RxJS 5, dispose был переименован в unsubscribe (спасибо @EricMartinez).

И из документов RxJS:

... когда мы больше не заинтересованы в получении данных по мере их поступления, мы вызываем dispose в нашей подписке.

---

Сохраните результат вашего звонка subscribe и позже распоряжаться подпиской в ​​течение ngOnDestroy,

RxJS 5:

export class SomeComponent {
  constructor (public service: Service) {
    this.subscription = this.service.someEvent.subscribe((x) => {...});
  }
  ngOnDestroy () {
      this.subscription.unsubscribe();
  }
}

RxJS <5:

export class SomeComponent {
  constructor (public service: Service) {
    this.subscription = this.service.someEvent.subscribe((x) => {...});
  }
  ngOnDestroy () {
      this.subscription.dispose();
  }
}

Answer 2

Вы можете сделать что-то вроде этого:

import { OnDestroy } from '@angular/core';
import { Subscription } from 'rxjs/Rx';

export class SomeComponent implements OnDestroy {
  private _subscription: Subscription;
  constructor(public service: Service) {
    this._subscription = this.service.someEvent.subscribe((x) => {
      // Do something
    });
  }
}

ngOnDestroy(){
  this._subscription.unsubscribe();
}