mirror of
https://github.com/SerenityOS/serenity.git
synced 2026-11-07 04:29:30 -10:00
LibWeb: Wait for the correct condition in Stream tests
We were signaling that the test is complete too early in some Stream tests. (cherry picked from commit f3f7f77dbc5a32f19069ef347b3ce5dc36525351)
This commit is contained in:
1 parent
0446c98053
commit
6bc2b81a9f
3 files changed
+15
-11
No files matched your search
@@ -39,19 +39,17 @@
|
||||
cancel() {},
|
||||
});
|
||||
|
||||
|
||||
const reader = transformStream.readable.getReader();
|
||||
reader.read().then(function processText({done, value}) {
|
||||
if (done)
|
||||
reader.read().then(function processText(result) {
|
||||
if (result.done) {
|
||||
done();
|
||||
return;
|
||||
}
|
||||
|
||||
println(value);
|
||||
println(result.value);
|
||||
reader.read().then(processText);
|
||||
}).then(() => {
|
||||
done();
|
||||
});
|
||||
|
||||
stream.pipeThrough(transformStream);
|
||||
|
||||
});
|
||||
</script>
|
||||
@@ -11,8 +11,13 @@
|
||||
return new Promise((resolve) => {
|
||||
const textDecoder = new TextDecoder("utf-8");
|
||||
println(textDecoder.decode(new Uint8Array(chunk)));
|
||||
|
||||
resolve();
|
||||
});
|
||||
},
|
||||
|
||||
close() {
|
||||
done();
|
||||
}
|
||||
}
|
||||
);
|
||||
@@ -40,8 +45,6 @@
|
||||
cancel() {},
|
||||
});
|
||||
|
||||
stream.pipeTo(writableStream).then(() => {
|
||||
done();
|
||||
});
|
||||
stream.pipeTo(writableStream);
|
||||
});
|
||||
</script>
|
||||
@@ -8,6 +8,10 @@
|
||||
resolve();
|
||||
});
|
||||
},
|
||||
|
||||
close() {
|
||||
done();
|
||||
}
|
||||
});
|
||||
|
||||
function sendMessage(message) {
|
||||
@@ -19,7 +23,6 @@
|
||||
|
||||
writer.ready.then(() => {
|
||||
writer.close();
|
||||
done();
|
||||
});
|
||||
}
|
||||
|
||||
|
||||
Reference in new issue
Block a user