From: Christopher Coté <chris@entropealabs.com>
Date: Fri, 3 Dec 2021 19:01:14 +0000 (-0500)
Subject: ensure request_id is incremented
X-Git-Url: http://git.entropealabs.com/?a=commitdiff_plain;h=ba1c33a0eedd674fa0b0392ecb031f0ec737f10a;p=wampex_client.git

ensure request_id is incremented
---

diff --git a/lib/client/session.ex b/lib/client/session.ex
index 0753a61..ec1b7c8 100644
--- a/lib/client/session.ex
+++ b/lib/client/session.ex
@@ -425,10 +425,10 @@ defmodule Wampex.Client.Session do
 
   defp remove_nil_values(message), do: Enum.reject(message, &is_nil/1)
 
-  defp maybe_inject_request_id(r_id, [@yield | _] = message), do: {r_id, message}
-  defp maybe_inject_request_id(r_id, [@hello | _] = message), do: {r_id, message}
-  defp maybe_inject_request_id(r_id, [@abort | _] = message), do: {r_id, message}
-  defp maybe_inject_request_id(r_id, [@error | _] = message), do: {r_id, message}
+  defp maybe_inject_request_id(r_id, [@yield | _] = message), do: {get_request_id(r_id), message}
+  defp maybe_inject_request_id(r_id, [@hello | _] = message), do: {get_request_id(r_id), message}
+  defp maybe_inject_request_id(r_id, [@abort | _] = message), do: {get_request_id(r_id), message}
+  defp maybe_inject_request_id(r_id, [@error | _] = message), do: {get_request_id(r_id), message}
 
   defp maybe_inject_request_id(r_id, message) do
     request_id = get_request_id(r_id)