为什么我可以在不订阅的情况下使用 Observable？

Question

我的问题是来自 Jeff Delaney 的示例 https://github.com/AngularFirebase/144-firestore-group-chat。 我试图理解为什么可以在没有 subscribe() 的情况下使用 observable。

例如来自 Github 存储库的 auth.service.ts：

import { Injectable } from '@angular/core';
import { Router } from '@angular/router';

import { auth } from 'firebase/app';
import { AngularFireAuth } from '@angular/fire/auth';
import {
  AngularFirestore,
  AngularFirestoreDocument
} from '@angular/fire/firestore';

import { Observable, of } from 'rxjs';
import { switchMap, first, map } from 'rxjs/operators';

@Injectable({ providedIn: 'root' })
export class AuthService {
  user$: Observable<any>;

  constructor(
    private afAuth: AngularFireAuth,
    private afs: AngularFirestore,
    private router: Router
  ) {
    this.user$ = this.afAuth.authState.pipe(
      switchMap(user => {
        if (user) {
          return this.afs.doc<any>(`users/${user.uid}`).valueChanges();
        } else {
          return of(null);
        }
      })
    );
  }

在构造函数和项目的其余部分中没有subscribe()，但该示例运行良好。

另一个例子是chat.service.ts这个函数：

getUserChats() {
    return this.auth.user$.pipe(
      switchMap(user => {
        return this.afs
          .collection('chats', ref => ref.where('uid', '==', user.uid))
          .snapshotChanges()
          .pipe(
            map(actions => {
              return actions.map(a => {
                const data: Object = a.payload.doc.data();
                const id = a.payload.doc.id;
                return { id, ...data };
              });
            })
          );
      })
    );
  }

为什么可以在没有subscribe() 的情况下使用 Observable？

Answer 1

在这个guard 文件中有async，它允许应用程序正常工作。由于守卫从 AuthService 中询问 getUser() 方法，返回时有 .toPromise()：

getUser() {
    return this.user$.pipe(first()).toPromise();
}