Packages

yggdrasil

1.0.0
6.0.3 6.0.2 6.0.1 6.0.0 5.0.2 5.0.1 5.0.0 4.1.6 4.1.5 4.1.4 4.1.3 4.1.2 4.1.1 4.1.0 4.0.0 3.3.4 3.3.3 3.3.2 3.3.1 3.3.0 3.2.3 3.2.2 3.2.1 3.2.0 3.1.0 3.0.3 3.0.2 3.0.1 3.0.0 2.1.0 2.0.8 2.0.7 2.0.6 2.0.5 2.0.4 2.0.3 2.0.2 2.0.1 2.0.0 1.2.3 1.2.2 1.2.1 1.1.1 1.1.0 1.0.0

Agnostic pub/sub with Redis, RabbitMQ and Postgres support

HexDocs

Current section

Files

Jump to
Readme
45 Versions
2 Dependencies
7 Dependants
Files
Activity
yggdrasil lib yggdrasil util forwarder.ex
Raw

lib/yggdrasil/util/forwarder.ex 

defmodule Yggdrasil.Util.Forwarder do

  use GenEvent



  def start_link(opts \\ []) do

    {:ok, manager} = GenEvent.start_link opts

    GenEvent.add_mon_handler manager, __MODULE__, %{}

    {:ok, manager}

  end



  def set_parent(forwarder, pid \\ nil) do

    parent = if pid == nil do self() else pid end

    ref = make_ref()

    GenEvent.notify forwarder, {:_parent, ref, parent}

    %{forwarder: forwarder, ref: ref}

  end



  def notify(%{forwarder: forwarder, ref: ref}, event) do

    GenEvent.notify forwarder, {ref, event}

  end



  #####################

  # GenEvent callbacks.



  def handle_event({:_parent, ref, pid}, state), do:

    {:ok, Map.put_new(state, ref, pid)}

  def handle_event({ref, event}, state) do

    case Map.fetch state, ref do

      {:ok, parent} ->

        send parent, event

      _ -> :ok

    end

    {:ok, state}

  end

  def handle_event(_any, state), do:

    {:ok, state}

end