javascript - 如何从 Node 请求创建 RxJs Observable

Question

目前可以显式创建一个可观察对象，如下所示:

const Rx = require("rxjs");
const request = require("request");

        return Rx.Observable.create(function (observer) {
            request(options, function (error, response, body) {
                if (error) {
                    observer.error(error);
                } else {
                    observer.next(response);
                    observer.complete();
                }
            });
        });

是否有一种简写方法可以使用 RxJs 库(或其他库)来执行此操作？

Answer 1

这是我的解决方案:

    return (options) => {
        const boundCallback = Rx.Observable.bindNodeCallback(request, toResponseOnly);
        return boundCallback(options);
    };

function toResponseOnly(response) {
    return response;
}

需要第二个函数来确保仅传递响应，否则回调的参数将作为数组传递。