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 test yggdrasil proxy_test.exs
Raw

test/yggdrasil/proxy_test.exs 

defmodule Yggdrasil.ProxyTest do

  use ExUnit.Case, async: true

  alias Yggdrasil.Proxy, as: Proxy

  alias Yggdrasil.Proxy.Data, as: Data



  test "subscribe default callback" do

    {:ok, proxy} = Proxy.start_link

    {:ok, handle} = Proxy.subscribe proxy, :broker, :channel

    Proxy.publish proxy, :broker, :channel, :test

    assert_receive %Data{broker: :broker, channel: :channel, data: :test}

    Proxy.unsubscribe proxy, handle

    assert GenEvent.which_handlers(proxy) == []

    Proxy.stop proxy

  end



  test "subscribe custom callback" do

    {:ok, proxy} = Proxy.start_link

    pid = self()

    {:ok, handle} = Proxy.subscribe proxy,

                                    :broker,

                                    :channel,

                                    &(send pid, {:custom, &1})

    Proxy.publish proxy, :broker, :channel, :test

    assert_receive {:custom, 

                    %Data{broker: :broker, channel: :channel, data: :test}}

    Proxy.unsubscribe proxy, handle

    assert GenEvent.which_handlers(proxy) == []

    Proxy.stop proxy

  end

end