How can I `await` on an Rx Observable?

by

You have to pass a promise to await. Convert the observable’s next event to a promise and await that.

if (condition) {
  await observable.first().toPromise();
}

Edit note: This answer originally used .take(1) but was changed to use .first() which avoids the issue of the Promise never resolving if the stream ends before a value comes through.

As of RxJS v8, toPromise will be removed. Instead, the above can be replaced with await firstValueFrom(observable)

More Related Contents:

  1. Can I fire and forget a promise in nodejs (ES7)?
  2. How to get current value of RxJS Subject or Observable?
  3. How do I destructure all properties into the current scope/closure in ES2015?
  4. BehaviorSubject vs Observable?
  5. Angular 4 Interceptor retry requests after token refresh
  6. Why do we need to use flatMap?
  7. How can I close a dropdown on click outside?
  8. How can I clone a JavaScript object except for one key?
  9. What is “callback hell” and how and why does RX solve it?
  10. What are the semantics of different RxJS subjects?
  11. Subject vs BehaviorSubject vs ReplaySubject in Angular
  12. Array.prototype.includes vs. Array.prototype.indexOf
  13. Chaining Observables in RxJS
  14. Promise.all behavior with RxJS Observables?
  15. RxJS sequence equivalent to promise.then()?
  16. Rxjs One Observable Feeding into Another
  17. RXJS Wait for all observables in an array to complete (or error)
  18. Rxjs toPromise() deprecated
  19. VSCode Linter ES6 ES7 Babel linter
  20. How to make one Observable sequence wait for another to complete before emitting?
  21. How to achieve a debounce service on input keyup event in angular2 with rxjs
  22. How to cancel a subscription in Angular2
  23. What is the difference between Observable and a Subject in rxjs?
  24. How to ‘wait’ for two observables in RxJS
  25. What is the difference between BehaviorSubject and Observable?
  26. Return an empty Observable
  27. Upgrading to Angular 10 – Fix CommonJS or AMD dependencies can cause optimization bailouts
  28. Property ‘catch’ does not exist on type ‘Observable’
  29. How to catch error and continue executing a sequence in RxJs?
  30. Observable Finally on Subscribe

Leave a Comment