javascript - 如何让 Horizo​​n 与 Promise 一起工作

Question

// Expected something like this
var message = await horizon('message').get(1).fetch().toPromise()

// In real life
horizon('message').get(1).fetch().subscribe((message)=>process(message))

// Simulate
promise = new Promise((resolve, reject)=>{
  horizon('message').get(1).fetch().subscribe(resolve,reject)
})

有没有更简单的方法来互操作 promise 和 Horizo​​n 的 rxjs observable ？