mirror of
https://github.com/servo/servo.git
synced 2025-06-25 09:34:32 +01:00
72 lines
2.2 KiB
JavaScript
72 lines
2.2 KiB
JavaScript
// META: title=Blob Stream
|
|
// META: script=../support/Blob.js
|
|
// META: script=../../streams/resources/test-utils.js
|
|
'use strict';
|
|
|
|
// Helper function that triggers garbage collection while reading a chunk
|
|
// if perform_gc is true.
|
|
async function read_and_gc(reader, perform_gc) {
|
|
const read_promise = reader.read();
|
|
if (perform_gc)
|
|
garbageCollect();
|
|
return read_promise;
|
|
}
|
|
|
|
// Takes in a ReadableStream and reads from it until it is done, returning
|
|
// an array that contains the results of each read operation. If perform_gc
|
|
// is true, garbage collection is triggered while reading every chunk.
|
|
async function read_all_chunks(stream, perform_gc = false) {
|
|
assert_true(stream instanceof ReadableStream);
|
|
assert_true('getReader' in stream);
|
|
const reader = stream.getReader();
|
|
|
|
assert_true('read' in reader);
|
|
let read_value = await read_and_gc(reader, perform_gc);
|
|
|
|
let out = [];
|
|
let i = 0;
|
|
while (!read_value.done) {
|
|
for (let val of read_value.value) {
|
|
out[i++] = val;
|
|
}
|
|
read_value = await read_and_gc(reader, perform_gc);
|
|
}
|
|
return out;
|
|
}
|
|
|
|
promise_test(async () => {
|
|
const blob = new Blob(["PASS"]);
|
|
const stream = blob.stream();
|
|
const chunks = await read_all_chunks(stream);
|
|
for (let [index, value] of chunks.entries()) {
|
|
assert_equals(value, "PASS".charCodeAt(index));
|
|
}
|
|
}, "Blob.stream()")
|
|
|
|
promise_test(async () => {
|
|
const blob = new Blob();
|
|
const stream = blob.stream();
|
|
const chunks = await read_all_chunks(stream);
|
|
assert_array_equals(chunks, []);
|
|
}, "Blob.stream() empty Blob")
|
|
|
|
promise_test(async () => {
|
|
const input_arr = [8, 241, 48, 123, 151];
|
|
const typed_arr = new Uint8Array(input_arr);
|
|
const blob = new Blob([typed_arr]);
|
|
const stream = blob.stream();
|
|
const chunks = await read_all_chunks(stream);
|
|
assert_array_equals(chunks, input_arr);
|
|
}, "Blob.stream() non-unicode input")
|
|
|
|
promise_test(async() => {
|
|
const input_arr = [8, 241, 48, 123, 151];
|
|
const typed_arr = new Uint8Array(input_arr);
|
|
let blob = new Blob([typed_arr]);
|
|
const stream = blob.stream();
|
|
blob = null;
|
|
garbageCollect();
|
|
const chunks = await read_all_chunks(stream, /*perform_gc=*/true);
|
|
assert_array_equals(chunks, input_arr);
|
|
}, "Blob.stream() garbage collection of blob shouldn't break stream" +
|
|
"consumption")
|