Merge pull request #58 from biyidev/fix/stream-mode-error-handling

[ Fix ] fixed stream mode can't handle error
anasfik · Jun 8, 2023 · 6862f7d · 6862f7d
2 parents 8a6c7f5 + 81cdfd0
commit 6862f7d
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/lib/src/core/networking/client.dart b/lib/src/core/networking/client.dart
@@ -275,9 +275,11 @@ abstract class OpenAINetworkingClient {
               .transform(utf8.decoder)
               .transform(openAIChatStreamLineSplitter);
 
+          String respondData = "";
           stream.listen(
             (value) {
               final data = value;
+              respondData += data;
 
               final dataLines = data
                   .split("\n")
@@ -300,7 +302,10 @@ abstract class OpenAINetworkingClient {
                   continue;
                 }
 
-                final decodedData = decodeToMap(data);
+                Map<String, dynamic> decodedData = {};
+                try {
+                  decodedData = decodeToMap(respondData);
+                } catch (error) {/** ignore, data has not been received */}
 
                 if (doesErrorExists(decodedData)) {
                   final error = decodedData[OpenAIStrings.errorFieldKey]