我如何在Rx Observable上“等待”？(How can I `await` on an Rx Observable?)

 我希望能够等待一个可观察的，例如 
 
const source = Rx.Observable.create(/* ... */)
//...
await source;
 
 天真的尝试导致等待立即解决并且不阻止执行 
 
 编辑：我的完整意向用例的伪代码是： 
 
if (condition) {
  await observable;
}
// a bunch of other code
 
 我知道我可以将其他代码移动到另一个单独的函数中，并将它传递给订阅回调函数，但我希望能够避免这种情况。 

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 usecase 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.

原文：https://stackoverflow.com/questions/34190375