From ba1c33a0eedd674fa0b0392ecb031f0ec737f10a Mon Sep 17 00:00:00 2001 From: =?utf8?q?Christopher=20Cot=C3=A9?= Date: Fri, 3 Dec 2021 14:01:14 -0500 Subject: [PATCH] ensure request_id is incremented --- lib/client/session.ex | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) 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) -- 2.45.3