diff --git a/lib/ex_openai/streaming_client.ex b/lib/ex_openai/streaming_client.ex
index 3f420a0..11713ba 100644
--- a/lib/ex_openai/streaming_client.ex
+++ b/lib/ex_openai/streaming_client.ex
@@ -80,7 +80,7 @@ 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})
+                message = st.convert_response_fx.(decoded)
                 forward_response(st.stream_to, {:data, message})
                 {"", st}