Skip to content

Commit 99f003e

Browse files
authored
Merge pull request #13 from leoafarias/main
Fixes chat completion stream losing first event data
2 parents f8289d2 + 921693d commit 99f003e

File tree

1 file changed

+8
-3
lines changed

1 file changed

+8
-3
lines changed

lib/src/core/networking/client.dart

Lines changed: 8 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -3,9 +3,9 @@ import 'dart:convert';
33
import 'dart:io';
44

55
import 'package:dart_openai/openai.dart';
6-
import 'package:http/http.dart' as http;
76
import 'package:dart_openai/src/core/builder/headers.dart';
87
import 'package:dart_openai/src/core/utils/logger.dart';
8+
import 'package:http/http.dart' as http;
99

1010
import '../exceptions/request_failure.dart';
1111

@@ -192,9 +192,14 @@ class OpenAINetworkingClient {
192192
client.send(request).then(
193193
(respond) {
194194
OpenAILogger.log("Starting to reading stream response");
195-
respond.stream.listen(
195+
196+
final stream = respond.stream
197+
.transform(utf8.decoder)
198+
.transform(const LineSplitter());
199+
200+
stream.listen(
196201
(value) {
197-
final String data = utf8.decode(value);
202+
final data = value;
198203

199204
final List<String> dataLines = data
200205
.split("\n")

0 commit comments

Comments
 (0)