StreamRunner
Install
Add as a dependency:
defp deps() do
[{:stream_runner, "~> 1.0"}]
endUsage
Run a Stream as an OTP process.
stream = Stream.interval(1000) |> Stream.each(&IO.inspect/1)
StreamRunner.start_link(stream)Add as a dependency:
defp deps() do
[{:stream_runner, "~> 1.0"}]
end
Run a Stream as an OTP process.
stream = Stream.interval(1000) |> Stream.each(&IO.inspect/1)
StreamRunner.start_link(stream)