Source code
Revision control
Copy as Markdown
Other Tools
Test Info: Warnings
- This test has a WPT meta file that expects 10 subtest issues.
- This WPT test may be referenced by the following Test IDs:
- /fetch/api/response/response-error-from-stream.any.html - WPT Dashboard Interop Dashboard
- /fetch/api/response/response-error-from-stream.any.serviceworker.html - WPT Dashboard Interop Dashboard
- /fetch/api/response/response-error-from-stream.any.sharedworker.html - WPT Dashboard Interop Dashboard
- /fetch/api/response/response-error-from-stream.any.worker.html - WPT Dashboard Interop Dashboard
// META: global=window,worker
// META: title=Response Receives Propagated Error from ReadableStream
function newStreamWithStartError() {
var err = new Error("Start error");
return [new ReadableStream({
start(controller) {
controller.error(err);
}
}),
err]
}
function newStreamWithPullError() {
var err = new Error("Pull error");
return [new ReadableStream({
pull(controller) {
controller.error(err);
}
}),
err]
}
function runRequestPromiseTest([stream, err], responseReaderMethod, testDescription) {
promise_test(test => {
return promise_rejects_exactly(
test,
err,
new Response(stream)[responseReaderMethod](),
'CustomTestError should propagate'
)
}, testDescription)
}
promise_test(test => {
var [stream, err] = newStreamWithStartError();
return promise_rejects_exactly(test, err, stream.getReader().read(), 'CustomTestError should propagate')
}, "ReadableStreamDefaultReader Promise receives ReadableStream start() Error")
promise_test(test => {
var [stream, err] = newStreamWithPullError();
return promise_rejects_exactly(test, err, stream.getReader().read(), 'CustomTestError should propagate')
}, "ReadableStreamDefaultReader Promise receives ReadableStream pull() Error")
// test start() errors for all Body reader methods
runRequestPromiseTest(newStreamWithStartError(), 'arrayBuffer', 'ReadableStream start() Error propagates to Response.arrayBuffer() Promise');
runRequestPromiseTest(newStreamWithStartError(), 'blob', 'ReadableStream start() Error propagates to Response.blob() Promise');
runRequestPromiseTest(newStreamWithStartError(), 'formData', 'ReadableStream start() Error propagates to Response.formData() Promise');
runRequestPromiseTest(newStreamWithStartError(), 'json', 'ReadableStream start() Error propagates to Response.json() Promise');
runRequestPromiseTest(newStreamWithStartError(), 'text', 'ReadableStream start() Error propagates to Response.text() Promise');
// test pull() errors for all Body reader methods
runRequestPromiseTest(newStreamWithPullError(), 'arrayBuffer', 'ReadableStream pull() Error propagates to Response.arrayBuffer() Promise');
runRequestPromiseTest(newStreamWithPullError(), 'blob', 'ReadableStream pull() Error propagates to Response.blob() Promise');
runRequestPromiseTest(newStreamWithPullError(), 'formData', 'ReadableStream pull() Error propagates to Response.formData() Promise');
runRequestPromiseTest(newStreamWithPullError(), 'json', 'ReadableStream pull() Error propagates to Response.json() Promise');
runRequestPromiseTest(newStreamWithPullError(), 'text', 'ReadableStream pull() Error propagates to Response.text() Promise');