improve NervesDHT.stream

visciang · Dec 9, 2017 · 44c68ac · 44c68ac
1 parent 666aec6
commit 44c68ac
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/lib/nerves_dht.ex b/lib/nerves_dht.ex
@@ -82,8 +82,7 @@ defmodule NervesDHT do
   """
   @spec stream(sensor, pin, interval) :: Enumerable.t
   def stream(sensor, pin, interval \\ @delay) do
-    Stream.interval(interval)
-    |> Stream.map(fn(_) -> read(sensor, pin, 0, 0) end)
+    Stream.repeatedly(fn -> Process.sleep(interval); read(sensor, pin, 0, 0) end)
   end
 
   @doc """