Merge pull request #132 from norpan/point_changefeeds

Fix point changefeeds

Author: hamiltop

lib/rethinkdb/response.ex

@@ -51,10 +51,7 @@ defmodule RethinkDB.Response do
     {code, resp} = case d["t"] do
       1  -> {:ok, %RethinkDB.Record{data: hd(data)}}
       2  -> {:ok, %RethinkDB.Collection{data: data}}
-      3  -> case d["n"] do
-          [2] -> {:ok, %RethinkDB.Feed{token: token, data: hd(data), pid: pid, note: d["n"]}}
-           _  -> {:ok, %RethinkDB.Feed{token: token, data: data, pid: pid, note: d["n"]}}
-        end
+      3  -> {:ok, %RethinkDB.Feed{token: token, data: data, pid: pid, note: d["n"]}}
       4  ->  {:ok, %RethinkDB.Response{token: token, data: d}}
       16  -> {:error, %RethinkDB.Response{token: token, data: d}}
       17  -> {:error, %RethinkDB.Response{token: token, data: d}}
@@ -63,4 +60,3 @@ defmodule RethinkDB.Response do
     {code, %{resp | :profile => d["p"]}}
   end
 end
-

test/changes_test.exs

@@ -57,4 +57,18 @@ defmodule ChangesTest do
     data = Task.await(t) 
     5 = Enum.count(data)
   end
+
+  test "point_changes" do
+    q = table(@table_name) |> get("0") |> changes
+    {:ok, changes} = {:ok, %Feed{}} = run(q)
+    t = Task.async fn ->
+      changes |> Enum.take(1)
+    end
+    data = %{"id" => "0"}
+    q = table(@table_name) |> insert(data)
+    {:ok, res} = run(q)
+    expected = res.data["id"]
+    [h|[]] = Task.await(t)
+    assert %{"new_val" => %{"id" => "0"}} = h
+  end
 end