Packages

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
recoverable_stream_ex lib recoverable_stream_ex.ex
Raw

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