Run a Stream as a process
Elixir
Switch branches/tags
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
Failed to load latest commit information.
config
lib
test
.gitignore
.travis.yml
LICENSE
README.md
mix.exs
mix.lock

README.md

StreamRunner

Install

Add as a dependency:

defp deps() do
  [{:stream_runner, "~> 1.0"}]
end

Usage

Run a Stream as an OTP process.

stream = Stream.interval(1000) |> Stream.each(&IO.inspect/1)
StreamRunner.start_link(stream)