From: Christopher Date: Tue, 18 Feb 2020 04:32:41 +0000 (-0600) Subject: change wampex start_link interface X-Git-Url: http://git.entropealabs.com/?a=commitdiff_plain;h=b9d9a7b4fb3ff7365f76fad7f676b4b2481520e5;p=wampex.git change wampex start_link interface --- diff --git a/lib/wampex.ex b/lib/wampex.ex index 56e0d6c..4f1b7ac 100644 --- a/lib/wampex.ex +++ b/lib/wampex.ex @@ -22,10 +22,10 @@ defmodule Wampex do | {:event, subscription_id :: integer(), publication_id :: integer(), details :: map(), arg_list :: arg_list(), arg_keyword :: arg_keyword()} - @spec start_link(name :: atom(), session_data :: Sess.t()) :: + @spec start_link(name: atom(), session_data: Sess.t()) :: {:ok, pid()} | {:error, {:already_started, pid()} | {:shutdown, term()} | term()} - def start_link(name, %Sess{} = session_data) when is_atom(name) do + def start_link(name: name, session: session_data) when is_atom(name) do Supervisor.start_link(__MODULE__, {name, session_data}, name: name) end diff --git a/test/wampex_test.exs b/test/wampex_test.exs index edbcd9e..245915b 100644 --- a/test/wampex_test.exs +++ b/test/wampex_test.exs @@ -93,18 +93,18 @@ defmodule WampexTest do test "callee registration" do name = TestCalleeRegistration - Wampex.start_link(name, @session) + Wampex.start_link(name: name, session: @session) TestCallee.start_link(self(), name, @device) assert_receive {:registered, id} end test "callee is invoked and responds and caller gets result" do callee_name = TestCalleeRespond - Wampex.start_link(callee_name, @session) + Wampex.start_link(name: callee_name, session: @session) TestCallee.start_link(self(), callee_name, @device) assert_receive {:registered, id} caller_name = TestCaller - Wampex.start_link(caller_name, @session) + Wampex.start_link(name: caller_name, session: @session) {:ok, ["ok"], %{"color" => "#FFFFFF"}} = Wampex.send_request( @@ -117,18 +117,18 @@ defmodule WampexTest do test "subscriber registration" do name = TestSubscriberRegister - Wampex.start_link(name, @session) + Wampex.start_link(name: name, session: @session) TestSubscriber.start_link(self(), name, "com.data.temp") assert_receive {:subscribed, id} end test "subscriber receives events from publisher" do name = TestSubscriberEvents - Wampex.start_link(name, @session) + Wampex.start_link(name: name, session: @session) TestSubscriber.start_link(self(), name, "com.data.temp") assert_receive {:subscribed, id} - Wampex.start_link(TestPublisher, @session) + Wampex.start_link(name: TestPublisher, session: @session) Wampex.cast_send_request( TestPublisher,