From e0b19675b3a1bb3c72ae54911fbe22dd7ab59bdc Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jos=C3=A9=20Valim?= Date: Wed, 19 Jun 2024 08:50:06 +0200 Subject: [PATCH] Update lib/broadway_cloud_pub_sub/pull_client.ex Co-authored-by: Max Wilson --- lib/broadway_cloud_pub_sub/pull_client.ex | 1 + 1 file changed, 1 insertion(+) diff --git a/lib/broadway_cloud_pub_sub/pull_client.ex b/lib/broadway_cloud_pub_sub/pull_client.ex index 140da35..b22ed89 100644 --- a/lib/broadway_cloud_pub_sub/pull_client.ex +++ b/lib/broadway_cloud_pub_sub/pull_client.ex @@ -171,6 +171,7 @@ defmodule BroadwayCloudPubSub.PullClient do %{message | "data" => Base.decode64!(encoded_data)} 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 headers(config) do