Current section
Files
Jump to
Current section
Files
lib/instream/connection/supervisor.ex
defmodule Instream.Connection.Supervisor do
@moduledoc false
use Supervisor
@doc false
def start_link(conn), do: Supervisor.start_link(__MODULE__, conn, name: conn)
@impl Supervisor
def init(conn) do
:ok =
case conn.config(:init) do
nil -> :ok
{mod, fun} -> apply(mod, fun, [conn])
{mod, fun, extra_args} -> apply(mod, fun, [conn | extra_args])
end
writer = conn.config(:writer)
workers =
if Code.ensure_loaded?(writer) and function_exported?(writer, :writer_workers, 1) do
writer.writer_workers(conn)
else
[]
end
Supervisor.init(workers, strategy: :one_for_one)
end
end