Rx Http Server An Rx based http server Example var RxHttpServer = require("rx-http-server"); var server = new RxHttpServer(); server.requests.subscribe(function(data) { data.response.writeHead(200, {"Content-Type": "text/plain"}); data.response.end("Hello from Rx!");}); server.listen(3000);