Skip to content

Instantly share code, notes, and snippets.

@obaranovskyi
Created December 10, 2021 08:54
Show Gist options
  • Save obaranovskyi/819b16907d3e374241a2dc01bac0e10b to your computer and use it in GitHub Desktop.
Save obaranovskyi/819b16907d3e374241a2dc01bac0e10b to your computer and use it in GitHub Desktop.
import { EmptyError, lastValueFrom, Observable, Subject } from 'rxjs';
async function demo<T>(observable: Observable<T>): Promise<void> {
try {
const promiseResult = await lastValueFrom(observable, { defaultValue: 25 });
console.log(promiseResult);
} catch (error) {
console.log(error instanceof EmptyError);
console.error(error);
}
}
const subject = new Subject();
demo(subject.asObservable());
subject.complete();
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment