Format

diff --git a/lib/client.ex b/lib/client.ex
index 0b6ca6ad6aa25a7c32c11833b6cae567a70f9ab1..651d0a01e863a2fa8c648d2c4bb03847d7dfe5d7 100644 (file)
--- a/lib/client.ex
+++ b/lib/client.ex
@@ -25,28 +25,17 @@ defmodule Wampex.Client do
 
   @spec init({atom(), Sess.t(), boolean()}) ::
           {:ok, {:supervisor.sup_flags(), [:supervisor.child_spec()]}} | :ignore
-  def init(
-        {name, %Sess{url: url, transport: t, serializer: s, protocol: p} = session_data,
-         reconnect}
-      ) do
+  def init({name, %Sess{url: url, transport: t, serializer: s, protocol: p} = session_data, reconnect}) do
     subscriber_registry = subscriber_registry_name(name)
     callee_registry = callee_registry_name(name)
     dependent_registry = dependent_registry_name(name)
     session_data = %Sess{session_data | name: name, roles: [Peer | session_data.roles]}
 
     children = [
-      {Registry,
-       [keys: :duplicate, name: subscriber_registry, partitions: System.schedulers_online()]},
+      {Registry, [keys: :duplicate, name: subscriber_registry, partitions: System.schedulers_online()]},
       {Registry, [keys: :unique, name: callee_registry, partitions: System.schedulers_online()]},
-      {Registry,
-       [keys: :unique, name: dependent_registry, partitions: System.schedulers_online()]},
-      {t,
-       name: name,
-       url: url,
-       session_data: session_data,
-       protocol: p,
-       serializer: s,
-       reconnect: reconnect}
+      {Registry, [keys: :unique, name: dependent_registry, partitions: System.schedulers_online()]},
+      {t, name: name, url: url, session_data: session_data, protocol: p, serializer: s, reconnect: reconnect}
     ]
 
     Supervisor.init(children, strategy: :one_for_one)

diff --git a/lib/client/handler.ex b/lib/client/handler.ex
index b153f9327015972262f9dec38518bf47da52c2de..d25430dbc250054665178d94ba3d9cafa974afa8 100644 (file)
--- a/lib/client/handler.ex
+++ b/lib/client/handler.ex
@@ -92,9 +92,7 @@ defmodule Wampex.Client.Handler do
     procedures = Module.get_attribute(env.module, :procedures) |> Enum.uniq()
     topics = Module.get_attribute(env.module, :topics) |> Enum.uniq()
 
-    Logger.info(
-      "#{env.module} | Registering topics: #{inspect(topics)}, procedures: #{inspect(procedures)}"
-    )
+    Logger.info("#{env.module} | Registering topics: #{inspect(topics)}, procedures: #{inspect(procedures)}")
 
     quote do
       require Logger

diff --git a/lib/client/session.ex b/lib/client/session.ex
index 7755b44f5c2ed62f7cd9e264148c151622c1de20..d2c042140057e139187f0c19b510fd1ea50cddd1 100644 (file)
--- a/lib/client/session.ex
+++ b/lib/client/session.ex
@@ -247,8 +247,7 @@ defmodule Wampex.Client.Session do
       send(pid, {:connected, name})
     end)
 
-    {:ok, %SL{sl | data: %Sess{session | connected: true}},
-     [{:next_event, :internal, :established}]}
+    {:ok, %SL{sl | data: %Sess{session | connected: true}}, [{:next_event, :internal, :established}]}
   end
 
   @impl true
@@ -379,8 +378,7 @@ defmodule Wampex.Client.Session do
 
   @impl true
   def handle_info({:set_message, message}, _, %SL{data: %Sess{} = sess} = data) do
-    {:ok, %SL{data | data: %Sess{sess | message: message}},
-     [{:next_event, :internal, :message_received}]}
+    {:ok, %SL{data | data: %Sess{sess | message: message}}, [{:next_event, :internal, :message_received}]}
   end
 
   @impl true