add render$ ($ for stream) method to express res

server/utils/rx.js

@@ -27,6 +27,15 @@ exports.observableQueryFromModel =
     return Rx.Observable.fromNodeCallback(Model[method], Model)(query);
   };
 
-exports.observeMethod = function observeMethod(Model, method) {
-  return Rx.Observable.fromNodeCallback(Model[method], Model);
+exports.observeMethod = function observeMethod(context, methodName) {
+  return Rx.Observable.fromNodeCallback(context[methodName], context);
+};
+
+// add rx methods to express
+exports.rxMiddleware = function rxMiddleware() {
+  return function rxMiddleware(req, res, next) {
+    // render to observable
+    res.render$ = Rx.Observable.fromNodeCallback(res.render, res);
+    next();
+  };
 };