fix streaming api

troubleshoot and fix publishing to websockets
pluralsh · Nov 20, 2024 · 982115e · 982115e
1 parent 8bdf9fc
commit 982115e
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/lib/console/ai/provider/openai.ex b/lib/console/ai/provider/openai.ex
@@ -49,7 +49,7 @@ defmodule Console.AI.OpenAI do
       access_key: opts.access_token,
       model: opts.model,
       base_url: opts.base_url,
-      stream: Stream.stream()
+      stream: Stream.stream() |> IO.inspect()
     }
   end
 

diff --git a/lib/console/ai/stream/exec.ex b/lib/console/ai/stream/exec.ex
@@ -12,7 +12,7 @@ defmodule Console.AI.Stream.Exec do
       %AIStream.SSE.Event{data: data}, acc ->
         case reducer.(data) do
           c when is_binary(c) ->
-            AIStream.publish(stream, c)
+            AIStream.publish(stream, c) |> IO.inspect()
             {:cont, [c | acc]}
           _ -> {:cont, acc}
         end