I'd like to be able to await on an observable, e.g.

const source = Rx.Observable.create(/* ... */)

//...

await source;

A naive attempt results in the await resolving immediately and not blocking execution

Edit:
The pseudocode for my full intended use case is:

if (condition) {

  await observable;

}

// a bunch of other code

I understand that I can move the other code into another separate function and pass it into the subscribe callback, but I'm hoping to be able to avoid that.