如何从节点请求创建 RxJs Observable答案

【问题标题】：How to create an RxJs Observable from a node request如何从节点请求创建 RxJs Observable
【发布时间】：2017-05-11 09:20:11
【问题描述】：

目前可以如下显式创建 observable：

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 库（或其他库）的速记方法？

【问题讨论】：

bindNodeCallbackreactivex.io/rxjs/class/es6/…
你已经在使用 RxJS 库了...

标签： javascript node.js rxjs rxjs5 node-request

【解决方案1】：

这是我的解决方案：

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

function toResponseOnly(response) {
    return response;
}

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

【讨论】：