Skip to content

Instantly share code, notes, and snippets.

@obaranovskyi
Last active December 10, 2021 07:03
Show Gist options
  • Save obaranovskyi/d6244dff07d6f394ab4be351c91c8ed3 to your computer and use it in GitHub Desktop.
Save obaranovskyi/d6244dff07d6f394ab4be351c91c8ed3 to your computer and use it in GitHub Desktop.
import { EmptyError, firstValueFrom, Observable, Subject } from 'rxjs';
async function demo<T>(observable: Observable<T>): Promise<void> {
try {
const result = await firstValueFrom(observable);
console.log(result);
} 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