Gostaria de aguardar um observável, por exemplo,

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

Uma tentativa ingênua resulta em aguardar a resolução imediata e não bloquear a execução

Edit: O pseudocódigo para toda a minha caixa de usuário pretendida é:

if (condition) {
  await observable;
}
// a bunch of other code

Entendo que posso mover o outro código para outra função separada e passá-lo para o retorno de chamada de inscrição, mas espero poder evitar isso.