fix: break early while reading stream data
This commit is contained in:
@@ -166,12 +166,6 @@ export const readStreamData = async (
|
||||
while (isReading) {
|
||||
const { done, value } = await reader.read();
|
||||
|
||||
if (done) {
|
||||
isReading = false;
|
||||
bufferManager.flush();
|
||||
break;
|
||||
}
|
||||
|
||||
try {
|
||||
const chunk = decoder.decode(value, { stream: true });
|
||||
|
||||
@@ -189,6 +183,12 @@ export const readStreamData = async (
|
||||
} catch (error) {
|
||||
bufferManager.add({ error });
|
||||
}
|
||||
|
||||
if (done) {
|
||||
isReading = false;
|
||||
bufferManager.flush();
|
||||
break;
|
||||
}
|
||||
}
|
||||
};
|
||||
|
||||
|
||||
Reference in New Issue
Block a user