| <!DOCTYPE html> |
| <script src='/resources/testharness.js'></script> |
| <script src='/resources/testharnessreport.js'></script> |
| <script> |
| |
| var controllerPrototype; |
| const rs = new ReadableStream({ |
| start: function(c) { |
| controllerPrototype = Object.getPrototypeOf(c); |
| } |
| }); |
| |
| async function pumpStream(streamReader) |
| { |
| const chunk = await streamReader.read(); |
| if (!chunk.done) |
| return pumpStream(streamReader); |
| } |
| |
| promise_test(async t => { |
| const enqueue = controllerPrototype.enqueue; |
| controllerPrototype.enqueue = null; |
| t.add_cleanup(async () => controllerPrototype.enqueue = enqueue); |
| |
| const response = await fetch("."); |
| await response.body.getReader().read(); |
| }, "Overwrite ReadableStreamDefaultController enqueue"); |
| |
| promise_test(async t => { |
| const error = controllerPrototype.error; |
| controllerPrototype.error = null; |
| t.add_cleanup(async () => controllerPrototype.error = error); |
| |
| const controller = new AbortController(); |
| const signal = controller.signal; |
| |
| const response = await fetch('./resources/lengthy-pass.py?delay=1', { signal }); |
| const reader = response.body.getReader(); |
| |
| controller.abort(); |
| |
| await promise_rejects_dom(t, "AbortError", reader.closed); |
| }, "Overwrite ReadableStreamDefaultController error"); |
| |
| promise_test(async t => { |
| const close = controllerPrototype.close; |
| controllerPrototype.close = null; |
| t.add_cleanup(async () => controllerPrototype.close = close); |
| |
| const response = await fetch("."); |
| const reader = response.body.getReader(); |
| await pumpStream(reader); |
| await reader.closed; |
| }, "Overwrite ReadableStreamDefaultController close"); |
| </script> |
