Revert bad merge

alexrudall · Nov 6, 2023 · 1e463b4 · 1e463b4
1 parent 1de4f79
commit 1e463b4
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/lib/openai/http.rb b/lib/openai/http.rb
@@ -49,9 +49,12 @@ def to_json_stream(user_proc:)
 
       proc do |chunk, _bytes, env|
         if env && env.status != 200
-          parser.feed(chunk) do |_type, data|
-            emit_json(json: data, user_proc: user_proc) unless data == "[DONE]"
-          end
+          raise_error = Faraday::Response::RaiseError.new
+          raise_error.on_complete(env.merge(body: JSON.parse(chunk)))
+        end
+
+        parser.feed(chunk) do |_type, data|
+          user_proc.call(JSON.parse(data)) unless data == "[DONE]"
         end
       end
     end