| {: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
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(
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,