scan default value

m1dnight · May 10, 2018 · efa81ee · efa81ee
1 parent d60b2f5
commit efa81ee
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/lib/obs.ex b/lib/obs.ex
@@ -307,8 +307,8 @@ defmodule Observables.Obs do
 
   More information: http://reactivex.io/documentation/operators/scan.html
   """
-  def scan({observable_fn, _parent_pid}, f) do
-    {:ok, pid} = GenObservable.start_link(Scan, [f])
+  def scan({observable_fn, _parent_pid}, f, default \\ nil) do
+    {:ok, pid} = GenObservable.start_link(Scan, [f, default])
 
     observable_fn.(pid)
 

diff --git a/lib/observables/scan.ex b/lib/observables/scan.ex
@@ -2,10 +2,10 @@ defmodule Observables.Scan do
   @moduledoc false
   use Observables.GenObservable
 
-  def init([proc]) do
+  def init([proc, default]) do
     Logger.debug("Scan: #{inspect(self())}")
     # We don't keep state in merge.
-    {:ok, %{:proc => proc, :intermediate => nil}}
+    {:ok, %{:proc => proc, :intermediate => default}}
   end
 
   def handle_event(v, %{:proc => proc, :intermediate => i}) do