allow opting into the no_responders behavior

nats-io · Oct 16, 2022 · f97ed0a · f97ed0a
1 parent 8076ea4
commit f97ed0a
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/lib/gnat/handshake.ex b/lib/gnat/handshake.ex
@@ -18,6 +18,7 @@ defmodule Gnat.Handshake do
     %{verbose: false}
     |> negotiate_auth(server_settings, user_settings)
     |> negotiate_headers(server_settings, user_settings)
+    |> negotiate_no_responders(server_settings, user_settings)
   end
 
   defp perform_handshake(tcp, user_settings) do
@@ -77,6 +78,13 @@ defmodule Gnat.Handshake do
     settings
   end
 
+  defp negotiate_no_responders(%{headers: true} = settings, _server_settings, %{no_responders: true}) do
+    Map.put(settings, :no_responders, true)
+  end
+  defp negotiate_no_responders(settings, _server_settings, _user_settings) do
+    settings
+  end
+
   defp upgrade_connection(tcp, %{tls: true, ssl_opts: opts}) do
     :ok = :inet.setopts(tcp, [active: true])
     :ssl.connect(tcp, opts, 1_000)