Packages

kadabra

0.3.2
0.6.3 0.6.2 0.6.1 0.6.0 0.5.0 0.4.5 0.4.4 0.4.3 0.4.2 0.4.1 0.4.0 0.3.8 0.3.7 0.3.6 0.3.5 0.3.4 0.3.3 0.3.2 0.3.1 0.3.0 0.2.2 0.2.1 0.2.0 0.1.6 0.1.5 0.1.4 0.1.3 0.1.2 0.1.1 0.1.0

HTTP2 client for Elixir

HexDocs

Current section

Files

Jump to
Readme
30 Versions
2 Dependencies
Dependants
Files
Activity
kadabra lib supervisor.ex
Raw

lib/supervisor.ex 

defmodule Kadabra.Supervisor do

  @moduledoc false



  use Supervisor

  import Supervisor.Spec



  alias Kadabra.Stream



  def start_link do

    Supervisor.start_link(__MODULE__, [], name: __MODULE__)

  end



  def init(_) do

    supervise([], strategy: :one_for_one)

  end



  def start_opts do

    [id: :erlang.make_ref, restart: :transient]

  end



  def start_stream(%{flow_control: flow} = conn, stream_id \\ nil) do

    stream = Stream.new(conn, flow.settings, stream_id || flow.stream_id)

    spec = worker(Stream, [stream], start_opts())

    Supervisor.start_child(__MODULE__, spec)

  end



  def start_encoder(ref) do

    start_hpack(ref, :encoder)

  end



  def start_decoder(ref) do

    start_hpack(ref, :decoder)

  end



  def start_hpack(ref, name) do

    spec = worker(Kadabra.Hpack, [{ref, name}], start_opts())

    Supervisor.start_child(__MODULE__, spec)

  end

end