Cas d'utilisation de l'opérateur Observable .do() (rxjs)

Question

 Contexte :

Je suis en train de construire une application angulaire 2 (avec une API Firebase). J'utilise le module AngularFire. Je me demandais comment je peux mélanger le module canActivate avec l'Observable d'authentification AngularFire, et j'ai trouvé ce poste . La réponse est de rendre le canActivate renvoie un Observable<boolean> :

canActivate(): Observable<boolean> {
  return this.auth
    .take(1)
    .map((authState: FirebaseAuthState) => !!authState)
    .do(authenticated => {
      if (!authenticated) this.router.navigate(['/login']);
    });
}

C'est la première fois que je vois l'Observable do et je n'arrive pas à comprendre ce qu'il fait vraiment ? La documentation officielle ne m'a pas aidé, et je n'ai pas trouvé d'exemples décents.

Question :

Quelqu'un peut-il apporter ici des exemples de .do() usage ? Et la différence avec .subscribe() ?

Answer 1

Mise à jour

Maintenant, c'est pipe( tap(...), ) au lieu de do()

Original

.do() est d'exécuter du code pour chaque événement. Une différence avec .map() est que la valeur de retour de .do() est ignorée et ne change pas la valeur que l'abonné reçoit.

Answer 2

Maintenant, c'est pipe( tap(...), ) au lieu de do()

const source = of(1, 2, 3, 4);
source.pipe(
  tap(val => console.log('I am tap: ',val)),
  filter(val =>  val > 2),
  map(val => val + 1)).subscribe((val) => {
  console.log('I am subscriber value after filtering: ', val);
});

Sortie :

I am tap:  1
I am tap:  2
I am tap:  3
I am subscriber value after filtering:  4
I am tap:  4
I am subscriber value after filtering:  5

*L'opérateur de tapotement ne modifie rien, on peut dire que c'est juste pour voir le flux.