fixed mistake in duc

lib/obs.ex

@@ -18,7 +18,8 @@ defmodule Observables.Obs do
     Take,
     CombineLatest,
     CombineLatestSilent,
-    Delay
+    Delay,
+    DistinctUntilChanged
   }
 
   alias Enum
@@ -185,7 +186,7 @@ defmodule Observables.Obs do
   More information: http://reactivex.io/documentation/operators/distinct.html and http://rxmarbles.com/#distinctUntilChanged
   """
   def distinctuntilchanged(observable, f \\ fn x, y -> x == y end) do
-    {:ok, pid} = GenObservable.start_link(Distinct, [f])
+    {:ok, pid} = GenObservable.start_link(DistinctUntilChanged, [f])
 
     GenObservable.send_to(observable, pid)
 

lib/observables/distinct_until_changed.ex

@@ -4,14 +4,14 @@ defmodule Observables.Operator.DistinctUntilChanged do
 
   def init([comparator]) do
     Logger.debug("Distinct Until Changed: #{inspect(self())}")
-    {:ok, %{:comp => comparator, :seen => []}}
+    {:ok, %{:comp => comparator, :last => []}}
   end
 
-  def handle_event(v, state = %{:comp => f, :seen => xs}) do
-    seen? = Enum.any?(xs, fn seen -> f.(v, seen) end)
+  def handle_event(v, state = %{:comp => f, :last => last}) do
+    same? = f.(v, last)
 
-    if not seen? do
-      {:value, v, %{:comp => f, :seen => []}}
+    if not same? do
+      {:value, v, %{:comp => f, :last => last}}
     else
       {:novalue, state}
     end

test/distinctuntilchanged_test.exs

@@ -7,24 +7,19 @@ defmodule DistinctUntilChangedTest do
   test "distinctuntilchanged" do
     testproc = self()
 
-    xs = [1, 1, 2, 2, 3, 3]
+    xs = [1,2,3,4,1,2,3,4]
 
-    expected = [1, 2, 3]
+    expected = [1,2,3,4,1,2,3,4]
 
     xs
     |> Obs.from_enum(100)
     |> Obs.distinctuntilchanged()
+    |> Obs.inspect()
     |> Obs.map(fn v -> send(testproc, v) end)
 
     expected
     |> Enum.map(fn x ->
-      assert_receive(^x, 1000, "did not get this message!")
-
-      receive do
-        ^x -> assert "duplicates" == ""
-      after
-        1000 -> :ok
-      end
+      assert_receive(^x, 1000, "did not get this message! #{inspect x}")
     end)
 
     receive do