From 05c6dcdf0f7b68abd6a5120f6d798f9e15469375 Mon Sep 17 00:00:00 2001
From: Berkeley Martinez <Berkeley@robotie.com>
Date: Mon, 29 Jun 2015 09:31:42 -0700
Subject: [PATCH] add render$ ($ for stream) method to express res

---
 server/utils/rx.js | 13 +++++++++++--
 1 file changed, 11 insertions(+), 2 deletions(-)

diff --git a/server/utils/rx.js b/server/utils/rx.js
index 8088e163e0..ed7e0ebf73 100644
--- a/server/utils/rx.js
+++ b/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();
+  };
 };