【发布时间】:2019-04-08 09:13:12
【问题描述】:
我正在使用request-promise-native 在我的 Node.js 应用程序中发出 http 请求。我想将其转换为 RxJS 可观察对象,但我不知道如何取消订阅。有什么有效的方法来做到这一点?
public getResponse(req: Request, res: Response) {
const url = config.url;
var options = {
uri: `${url}`,
body: JSON.stringify(providerResponse),
method: 'POST',
headers: {
'Content-Type': 'application/json'
}
};
const responseObs = from(request(options)); // convert promise to observable using from
responseObs.subscribe(response => {
res.setHeader('content-type', 'application/json');
res.send(response)
}, error => {
console.error(error)
})
};
【问题讨论】:
-
你应该返回
responseObs.subscribe(...) -
如果我返回订阅。这会自动退订吗?
标签: node.js promise rxjs observable