Remove passed tuple

dvcrn · Jan 31, 2025 · 73a8679 · 73a8679
1 parent 1905dc5
commit 73a8679
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/lib/ex_openai/streaming_client.ex b/lib/ex_openai/streaming_client.ex
@@ -80,8 +80,16 @@ defmodule ExOpenAI.StreamingClient do
             case Jason.decode(attempt) do
               {:ok, decoded} ->
                 # Once successfully decoded, forward, and reset partial buffer
-                message = st.convert_response_fx.({:ok, decoded})
-                forward_response(st.stream_to, {:data, message})
+                case st.convert_response_fx.({:ok, decoded}) do
+                  {:ok, message} ->
+                    forward_response(st.stream_to, {:data, message})
+
+                  e ->
+                    Logger.warning(
+                      "Something went wrong trying to decode the response: #{inspect(e)}"
+                    )
+                end
+
                 {"", st}
 
               {:error, _} ->