LayoutTests/streams/readableStream-then.html

<!DOCTYPE html>
<script src='../resources/testharness.js'></script>
<script src='../resources/testharnessreport.js'></script>
<script>
promise_test(async () => {
    const chunks = [];
    const stream = new ReadableStream({
        start : (controller) => {
            controller.close();
        }
    });
    await new Promise(resolve => setTimeout(resolve, 0));
    const reader = stream.getReader();

    Object.prototype.then = function(chunk) {
        chunks.push(chunk);
    }
    await reader.read();
    delete Object.prototype.then;

    assert_array_equals(chunks, []);
}, 'close synchronously');

promise_test(async () => {
    const chunks = [];
    const stream = new ReadableStream({
        start : (controller) => {
            controller.close();
        }
    });
    await new Promise(resolve => setTimeout(resolve, 0));
    const reader = stream.getReader();

    Object.prototype.then = function(chunk) {
        chunks.push(chunk);
    }
    await reader.read();
    delete Object.prototype.then;

    assert_array_equals(chunks, []);
}, 'close asynchronously');

promise_test(async () => {
    const chunks = [];
    const stream = new ReadableStream({
        start : async (controller) => {
            await new Promise(resolve => setTimeout(resolve, 0));
            controller.enqueue('chunk');
        }
    });
    const reader = stream.getReader();

    Object.prototype.then = function(chunk) {
        chunks.push(chunk);
    }
    await reader.read();
    delete Object.prototype.then;

    assert_array_equals(chunks, []);
}, 'enqueue synchronously');

promise_test(async () => {
    const chunks = [];
    const stream = new ReadableStream({
        start : async (controller) => {
            await new Promise(resolve => setTimeout(resolve, 0));
            controller.enqueue('chunk');
        }
    });
    const reader = stream.getReader();

    Object.prototype.then = function(chunk) {
        chunks.push(chunk);
    }
    await reader.read();
    delete Object.prototype.then;

    assert_array_equals(chunks, []);
}, 'enqueue asynchronously');
</script>