]> Entropealabs - wampex_router.git/commitdiff
change wampex start_link interface
authorChristopher <chris@entropealabs.com>
Tue, 18 Feb 2020 04:32:41 +0000 (22:32 -0600)
committerChristopher <chris@entropealabs.com>
Tue, 18 Feb 2020 04:32:41 +0000 (22:32 -0600)
lib/wampex.ex
test/wampex_test.exs

index 56e0d6cc2eea3b06333a752981e9a42e9abcc5cd..4f1b7aca68432e5a3112e75e7ebe8ff7c7204343 100644 (file)
@@ -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
 
index edbcd9ebb7097a67bb1735df6144c3b152dd0137..245915b664b7ba2eb0c20cedcda554d07e1c5bfc 100644 (file)
@@ -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,