Packages
recoverable_stream_ex
1.0.0
By extracting evaluation of the source stream into a separate process `RecoverableStream` provides a way to isolate upstream errors and recover from them.
Current section
Files
Jump to
Current section
Files
lib/recoverable_stream_ex.ex
defmodule RecoverableStreamEx do
@moduledoc false
use Application
def start(_type, _args) do
opts = [
strategy: :one_for_one,
name: RecoverableStreamEx.Supervisor
]
children = [
RecoverableStream.TasksPool.child_spec(RecoverableStream.TasksPool)
]
Supervisor.start_link(children, opts)
end
end