last-value-from-base-example.ts

import { lastValueFrom, Observable, Subject } from 'rxjs';

async function demo<T>(observable: Observable<T>): Promise<void> {
  const result = await lastValueFrom(observable);

  console.log(result);
}

const subject = new Subject();
demo(subject.asObservable());
subject.next(1);
subject.next(2);
subject.next(3);
subject.next(4);
subject.next(5);
subject.complete();