Awaitable Observables :: Example 2

rxjs-awaitable-observables-ex2.ts

import { Component, OnInit } from '@angular/core';

@Component({ /* ... */ })
export class MyComponent implements OnInit {

  public readonly currentUser$: Observable<User | undefined> = this.store.select(fromStore.getCurrentUser);

  public constructor(
    private readonly store: Store<AppState>,
    private readonly my: MyService,
  ) {}

  public async doSomethingIfUserDefinedViaRxJS(): Promise<void> {
    this.currentUser$
      .pipe(
        first(),
        filter((user?: User) => !!v),
      )
      .subscribe((user: User) => /* ... */);
  }

  public async doSomethingIfUserDefined(): Promise<void> {
    if (!await this.currentUser$) return;

    // ...
  }

  public async doSomethingWithCurrentUserViaRxJS(): Promise<void> {
    this.currentUser$
        .pipe(first())
        .subscribe(user => this.my.doSomething(user));
  }

  public async doSomethingWithCurrentUser(): Promise<void> {
    this.my.doSomething(await this.currentUser$);
  }

}