fix add server/utils/rx to commit

server/utils/rx.js

@@ -0,0 +1,25 @@
+var Rx = require('rx');
+var debug = require('debug')('freecc:rxUtils');
+
+exports.saveUser = function saveUser(user) {
+  return new Rx.Observable.create(function(observer) {
+    if (!user || typeof user.save !== 'function') {
+      debug('no user or save method');
+      observer.onNext();
+      return observer.onCompleted();
+    }
+    user.save(function(err, savedUser) {
+      if (err) {
+        return observer.onError(err);
+      }
+      debug('user saved');
+      observer.onNext(savedUser);
+      observer.onCompleted();
+    });
+  });
+};
+
+exports.observableQueryFromModel =
+  function observableQueryFromModel(Model, method, query) {
+    return Rx.Observable.fromNodeCallback(Model[method], Model)(query);
+  };