Temp

Author: danielcompton

src/rethinkdb/net.clj

@@ -79,7 +79,7 @@
       (do (swap! (:conn conn) update-in [:pending token] #(dissoc % :cursor))
           (s/put-all! cursor (conj resp ::done)))
       (do (swap! (:conn conn) update :pending #(dissoc % token))
-          (s/put! result resp)
+          (s/put-all! result resp)
           (s/close! result)))))
 
 (defn append-result [conn token resp]
@@ -96,7 +96,7 @@
   (let [{type :t resp :r etype :e notes :n :as json-resp} resp]
     (case (int type)
       (1 5) ;; Success atom, server info
-      (deliver-result conn token (first resp))
+      (deliver-result conn token resp)
 
       2 ;; Success sequence
       (deliver-result conn token resp)

test/rethinkdb/async_test.clj

@@ -29,6 +29,7 @@
                                   (async/into [])
                                   (async/<!!))
                              expected)
+      ;; Insert (success atom)
       [{:deleted   0
         :errors    0
         :inserted  2
@@ -37,7 +38,15 @@
         :unchanged 0}]
       (-> (r/table utils/test-table)
           (r/insert pokemon))
+
+      ;; Success sequence
       pokemon (-> (r/table utils/test-table))
+
+      ;; Success atom
       [pokemon] (-> (r/table utils/test-table) (r/order-by :name))
 
-      )))
+      ;; Changefeed
+      (map #(hash-map :new_val %) pokemon)
+      (-> (r/table utils/test-table)
+          (r/changes {:include-initial true})
+          (r/limit 2)))))