Packages

kadabra

0.4.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 stream_supervisor.ex
Raw

lib/stream_supervisor.ex 

defmodule Kadabra.StreamSupervisor do

  @moduledoc false



  use Supervisor

  import Supervisor.Spec



  alias Kadabra.Stream



  def start_link(ref) do

    name = via_tuple(ref)

    Supervisor.start_link(__MODULE__, :ok, name: name)

  end



  def via_tuple(ref) do

    {:via, Registry, {Registry.Kadabra, {ref, __MODULE__}}}

  end



  def start_opts(id \\ :erlang.make_ref()) do

    [id: id, restart: :transient]

  end



  def start_stream(%{ref: ref} = config, stream_id, window, max_frame) do

    stream = Stream.new(config, stream_id, window, max_frame)

    Supervisor.start_child(via_tuple(ref), [stream])

  end



  def send_frame(ref, stream_id, frame) do

    ref

    |> Stream.via_tuple(stream_id)

    |> Stream.call_recv(frame)

  end



  def stop(ref) do

    ref

    |> via_tuple()

    |> Supervisor.stop()

  end



  def init(:ok) do

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

    supervise([spec], strategy: :simple_one_for_one)

  end

end