diff --git a/server/utils/rx.js b/server/utils/rx.js
new file mode 100644
index 0000000000..8a4003c00c
--- /dev/null
+++ b/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);
+  };