Rx.Observable Node HTTP server

server.js

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

function observableServer(server) {
  return Rx.Observable.fromEventPattern(
    server.addListener.bind(server, 'request'),
    server.removeListener.bind(server, 'request'),
    (req, res) => ({req, res})
  ).takeUntil(Rx.Observable.fromEvent(server, 'close'));
}

const server = http.createServer((req, res) =>
  res.writeHead(200, {'Content-Type': 'text/plain'}))
  .listen(8000);

observableServer(server)
  .subscribe(e => e.res.end('Hello World\n'));

process.on('SIGINT', server.close.bind(server));