<!doctype html>
<html>
  <head>
    <meta charset="utf-8">
    <title>Response Receives Propagated Error from ReadableStream</title>
    <script src="/resources/testharness.js"></script>
    <script src="/resources/testharnessreport.js"></script>
  </head>
  <body>
    <script>
      function CustomTestError() {
        const error = Error();
        error.name = 'custom-test-error';
        return error;
      }

      function newStreamWithStartError() {
        return new ReadableStream({
          start(controller) {
            controller.error(CustomTestError());
          }
        })
      }

      function newStreamWithPullError() {
        return new ReadableStream({
          pull(controller) {
            controller.error(CustomTestError());
          }
        })
      }

      function runRequestPromiseTest(stream, responseReaderMethod, testDescription) {
        promise_test(test => {
          return promise_rejects(
            test,
            CustomTestError(),
            new Response(stream)[responseReaderMethod](),
            'CustomTestError should propagate'
          )
        }, testDescription)
      }


      promise_test(test => {
        return promise_rejects(test, CustomTestError(), newStreamWithStartError().getReader().read(), 'CustomTestError should propagate')
      }, "ReadableStreamDefaultReader Promise receives ReadableStream start() Error")

      promise_test(test => {
        return promise_rejects(test, CustomTestError(), newStreamWithPullError().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');
    </script>
  </body>
</html>