We were signaling that the test is complete too early in some Stream tests.
@@ -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() {
}
);
@@ -40,8 +45,6 @@
- stream.pipeTo(writableStream).then(() => {
- });
+ stream.pipeTo(writableStream);
@@ -8,6 +8,10 @@
},
function sendMessage(message) {
@@ -19,7 +23,6 @@
writer.ready.then(() => {
writer.close();