Wrap Node's https.request() in an RxJS observable

nodeRxXhr.js

var https = require('https');
var Rx = require('rx');

/**
Wrap Node's https.request() in an RxJS observable
**/
function nodeRxXhr(options, postData) {
    return Rx.Observable.create(function(obs) {
        var req = https.request(options, function(res) {
            res.setEncoding('utf8');
            var body = '';
            res.on('data', function(x) { body += x });
            res.on('end', function() {
                obs.onNext({
                    statusCode: res.statusCode,
                    httpVersion: res.httpVersion,
                    statusMessage: res.statusMessage,
                    headers: res.headers,
                    body: body,
                });
                obs.onCompleted();
            });
        });

        req.on('error', function(err) { obs.onError(err) });
        if (postData != null) { req.write(postData); }
        req.end();

        return function() { req.abort() };
    });
}