Packages

flowex

0.1.2
0.5.4 0.5.3 0.5.2 0.5.1 0.5.0 0.4.0 0.3.0 0.2.0 0.1.2 0.1.1 0.1.0

Flow-Based Programming with Elixir GenStage.

HexDocs

Current section

Files

Jump to
Readme
11 Versions
1 Dependency
Dependants
Files
Activity
flowex lib flowex supervisor.ex
Raw

lib/flowex/supervisor.ex 

defmodule Flowex.Supervisor do

  use Supervisor



  def start_link(pipeline_module) do

    Supervisor.start_link(__MODULE__, pipeline_module)

  end



  def init(pipeline_module) do

    name = String.to_atom("Flowex.Producer_#{inspect pipeline_module}_#{inspect make_ref()}")

    children = [

      worker(Flowex.Producer, [nil, [name: name]], id: name)

    ]



    supervise(children, strategy: :one_for_one)

  end

end