将某种类型的回调转换为可观察的

Question

我有一个 api 这样的：（这是一个微信小程序api。）

wx.request({
  url: 'test.php', 
  data: {
    x: '',
    y: ''
  },
  header: {
    'content-type': 'application/json' 
  },
  success (res) {
    console.log(res.data)
  },
  fail(err) {
    console.log(err)
  },
  complete(res) {
    console.log(res.data)
  }
})

但是我想这样使用它：（我想像使用 observable 一样使用它。）

rxwx.request({
  url: 'test.php', 
  data: {
    x: '',
    y: ''
  },
  header: {
    'content-type': 'application/json' 
  },
}).subscribe(
  (res) => {
    console.log(res.data)
  },
  (err) => {
    console.log(err)
  },
  (res) => {
    console.log(res.data)
  }
)

我无法将 wx.login 转换为 bindCallback 或 bindNodeCallback。请帮忙。提前致谢 :D

Answer 1

改为使用 Observable 构造函数

const request=new Observable(emitter=>{
wx.request({
  url: 'test.php', 
  data: {
    x: '',
    y: ''
  },
  header: {
    'content-type': 'application/json' 
  },
  success:emitter.next
  fail:emitter.error
  complete:emitter.complete
})

return ()=>{ //... clearn up logic here  }
}

将某种类型的回调转换为可观察的

convert certain type of callback to to observable

rxjs

wechat-miniprogram