Отмена наблюдаемого после первого раза - Angular2, TypeScript, rxjs/Observable

Question

Я делаю проверку существующего входа в начале приложения, который я хочу только один раз. Как мы отменим подписку после первого раза? Я попытался взять (1), но это, похоже, не работает.

this.auth.getUserData().take(1).subscribe(data => { // the take(1) doesn't work 
    console.log('Firebase responded with success.'); 
    this.rootPage = TabsPage; 
}, err => { 
    console.log('Firebase responded with error.', err); 
    this.rootPage = LoginEmailPage; 
} 
); 

Answer 1

Вы пробовали first() вместо take(1)

В зависимости от импорта на уровне модуля, вы можете добавить импорт для оператора в первой

import 'rxjs/add/operator/first' 

В то время как это делает на самом деле не отменяет подписку, она завершает наблюдение, которое, как я считаю, является тем, что подразумевалось.

EDIT: добавление явного способа отменить подписку, как первоначально запрошенную OP

Результат .subscribe (...) возвращает обработчик подписки. Вы можете использовать эту ручку, чтобы явно отменить подписку, и код будет выглядеть следующим образом:

let subscription = this.auth.getUserData().take(1).subscribe(data => { // the take(1) doesn't work 
    console.log('Firebase responded with success.'); 
    this.rootPage = TabsPage; 
    subscription.unsubscribe(); 
}, err => { 
    console.log('Firebase responded with error.', err); 
    this.rootPage = LoginEmailPage; 
} 
); 

Хотя это кажется неправильным явно отменить подписку в этом случае общая картина, чтобы создать подписку в ngOnInit() или на основе по событиям после init и отменить ожидающие подписки в пределах ngOnDestroy().