Update changes to take optargs

- Rename changes arg from table to xs
- Add a new arity to changes to pass optargs

Fixes #112, Fixes #76

CHANGELOG.md

@@ -5,6 +5,8 @@ All notable changes to this project will be documented in this file. This change
 ## [Unreleased]
 ### Changed
 - Disable Nagle's algorithm (set TCP NO_DELAY to true). This provides a speedup of around 30-40x for small queries on Linux. [#114](https://github.com/apa512/clj-rethinkdb/pull/114)
+- Added a new arity to `changes` that allows you to pass optargs. [#112](https://github.com/apa512/clj-rethinkdb/issues/112)
+- Renamed changes arg from `table` to `xs`. [#76](https://github.com/apa512/clj-rethinkdb/issues/76)
 
 
 ## [0.11.0] - 2015-10-19

src/rethinkdb/query.cljc

@@ -135,10 +135,12 @@
   (term :INDEX_WAIT (concat [table] index-names)))
 
 (defn changes
-  "Return an infinite stream of objects representing changes to a table or a
-  document."
-  [table]
-  (term :CHANGES [table]))
+  "Return an infinite stream of objects representing changes to a table, sequence,
+   or a document."
+  ([xs]
+   (term :CHANGES [xs]))
+  ([xs optargs]
+   (term :CHANGES [xs] optargs)))
 
 ;;; Writing data
 

test/rethinkdb/core_test.clj

@@ -151,18 +151,18 @@
       (r/run (-> (r/db test-db)
                  (r/table test-table)
                  (r/insert (take 2 (repeat {:name "Test"})))) conn)
-      (is (= "Test" ((comp :name :new_val) (first @changes))))))
+      (is (= "Test" (get-in (first @changes) [:new_val :name])))))
   (with-open [conn (r/connect :db test-db)]
     (let [changes (future
                     (-> (r/db test-db)
                         (r/table test-table)
-                        r/changes
+                        (r/changes {:include-states true})
                         (r/run conn)))]
       (Thread/sleep 500)
       (r/run (-> (r/table test-table)
                  (r/insert (take 2 (repeat {:name "Test"}))))
              conn)
-      (is (= "Test" ((comp :name :new_val) (first @changes)))))))
+      (is (= {:state "ready"} (first @changes))))))
 
 (deftest document-manipulation
   (with-open [conn (r/connect :db test-db)]