Update lib/broadway_cloud_pub_sub/pull_client.ex

Co-authored-by: Max Wilson <io@maxwilson.dev>
dashbitco · Jun 19, 2024 · e0b1967 · e0b1967
1 parent aa30999
commit e0b1967
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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