Угловой 2 с использованием RxJS - take (1) vs first()

Question

Я нашел несколько реализаций Auth Guard, в которых используется take(1). В моем проекте я использовал first() для удовлетворения моих потребностей. Это работает так же? Или один из них может иметь преимущества или около того.

import 'rxjs/add/operator/map'; 
import 'rxjs/add/operator/first'; 
import { Observable } from 'rxjs/Observable'; 

import { Injectable } from '@angular/core'; 
import { CanActivate, Router, ActivatedRouteSnapshot, RouterStateSnapshot } from '@angular/router'; 
import { AngularFire } from 'angularfire2'; 

@Injectable() 
export class AuthGuard implements CanActivate { 

    constructor(private angularFire: AngularFire, private router: Router) { } 

    canActivate(route: ActivatedRouteSnapshot, state: RouterStateSnapshot): Observable<boolean> | boolean { 
     return this.angularFire.auth.map(
      (auth) => { 
       if (auth) { 
        this.router.navigate(['/dashboard']); 
        return false; 
       } else { 
        return true; 
       } 
      } 
     ).first(); // Just change this to .take(1) 
    } 
} 

Answer 1

Операторы first() и take() не то же самое.

first() оператор принимает необязательную predicate функцию и выдает error уведомления, когда значение не соответствует, когда источник завершен.

Например, это будет излучать ошибку:

Rx.Observable.empty() 
    .first() 
    .subscribe(
    val => console.log(val), 
    err => console.log('Error', err) 
); 

..., а также следующим образом:

Rx.Observable.range(1, 5) 
    .first(val => val > 6) 
    .subscribe(
    val => console.log(val), 
    err => console.log('Error', err) 
); 

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

Rx.Observable.range(1, 5) 
    .first() 
    .subscribe(
    val => console.log(val), 
    err => console.log('Error', err) 
); 

С другой стороны, take(1) просто берет первое значение и завершает работу. Никакой дополнительной логики не задействовано.

Rx.Observable.range(1, 5) 
    .take(1) 
    .subscribe(
    val => console.log(val), 
    err => console.log('Error', err) 
); 

Затем с пустым источником Наблюдаемые не будет излучать какую-либо ошибку:

Rx.Observable.empty() 
    .take(1) 
    .subscribe(
    val => console.log(val), 
    err => console.log('Error', err) 
); 

Answer 2

Там одна очень важная разница, которая нигде не упоминается.

берет (1) испускает 1, завершает, отписывается

первого() испускает 1, завершается, но не отказаться от подписки.

Это означает, что ваш наблюдаемый вверх по-прежнему будет горячим после первого(), который, вероятно, не ожидается.

Answer 3

Похоже, что в RxJS 5.2.0 .Первый() оператор имеет bug,

Из-за этой ошибки .Снять (1) и .first() может вести себя совсем иначе, если вы используете их с выключателем карта:

с взятием (1) вы получите behviour, как и ожидалось:

var x = Rx.Observable.interval(1000) 
    .do(x=> console.log("One")) 
    .take(1) 
    .switchMap(x => Rx.Observable.interval(1000)) 
    .do(x=> console.log("Two")) 
    .subscribe((x) => {}) 

// In console you will see: 
// One 
// Two 
// Two 
// Two 
// Two 
// etc... 

Но с .Первый() вы получите неправильное поведение:

var x = Rx.Observable.interval(1000) 
    .do(x=> console.log("One")) 
    .first() 
    .switchMap(x => Rx.Observable.interval(1000)) 
    .do(x=> console.log("Two")) 
    .subscribe((x) => {}) 

// In console you will see: 
// One 
// One 
// Two 
// One 
// Two 
// One 
// etc... 

Здесь ссылаются на codepen