From 017eb79f40b814e013cef36ff7e982c9c7c15a21 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jos=C3=A9=20Valim?= Date: Wed, 19 Jun 2024 08:50:37 +0200 Subject: [PATCH] Update lib/broadway_cloud_pub_sub/pull_client.ex --- lib/broadway_cloud_pub_sub/pull_client.ex | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib/broadway_cloud_pub_sub/pull_client.ex b/lib/broadway_cloud_pub_sub/pull_client.ex index b22ed89..20e379d 100644 --- a/lib/broadway_cloud_pub_sub/pull_client.ex +++ b/lib/broadway_cloud_pub_sub/pull_client.ex @@ -172,7 +172,7 @@ defmodule BroadwayCloudPubSub.PullClient do end defp decode_message(%{"data" => nil} = message), do: message - defp decode_message(message) when is_map(message) and not is_map_key(message, "data"), do: message + defp decode_message(%{} = message) when not is_map_key(message, "data"), do: message defp headers(config) do token = get_token(config)