Как подписаться на событие эмиттер один раз?

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 возвращает instance of Disposable, который имеет метод dispose.

Или если вы используете RxJS 5, dispose has been renamed to unsubscribe (спасибо @EricMartinez).

И от RxJS docs:

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

---

магазин результат вашего вызова 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(); 
}