Unified error handling for WritableStream

third_party/WebKit/LayoutTests/http/tests/streams/piping/multiple-propagation.js

-'use strict';
-
-if (self.importScripts) {
-  self.importScripts('/resources/testharness.js');
-  self.importScripts('../resources/test-utils.js');
-  self.importScripts('../resources/recording-streams.js');
-}
-
-const error1 = new Error('error1!');
-error1.name = 'error1';
-
-const error2 = new Error('error2!');
-error2.name = 'error2';
-
-promise_test(t => {
-  const rs = recordingReadableStream({
-    start(c) {
-      c.error(error1);
-    }
-  });
-  const ws = recordingWritableStream({
-    start(c) {
-      c.error(error2);
-    }
-  });
-
-  // Trying to abort a stream that was errored will give that error back
-  return promise_rejects(t, error2, rs.pipeTo(ws), 'pipeTo must reject with the writable stream\'s error').then(() => {
-    assert_array_equals(rs.events, []);
-    assert_array_equals(ws.events, []);
-
-    return Promise.all([
-      promise_rejects(t, error1, rs.getReader().closed, 'the readable stream must be errored with error1'),
-      promise_rejects(t, error2, ws.getWriter().closed, 'the writable stream must be errored with error2')
-    ]);
-  });
-
-}, 'Piping from an errored readable stream to an errored writable stream');
-
-promise_test(t => {
-  const rs = recordingReadableStream({
-    start(c) {
-      c.error(error1);
-    }
-  });
-  const ws = recordingWritableStream({
-    start(c) {
-      c.error(error2);
-    }
-  });
-
-  return promise_rejects(t, error1, rs.pipeTo(ws, { preventAbort: true }),
-    'pipeTo must reject with the readable stream\'s error')
-  .then(() => {
-    assert_array_equals(rs.events, []);
-    assert_array_equals(ws.events, []);
-
-    return Promise.all([
-      promise_rejects(t, error1, rs.getReader().closed, 'the readable stream must be errored with error1'),
-      promise_rejects(t, error2, ws.getWriter().closed, 'the writable stream must be errored with error2')
-    ]);
-  });
-
-}, 'Piping from an errored readable stream to an errored writable stream; preventAbort = true');
-
-// TODO(ricea): Revert to the upstream version of this test once https://github.com/whatwg/streams/pull/634 is
-// resolved and WritableStream.js has been updated to match.
-promise_test(t => {
-  const rs = recordingReadableStream({
-    start(c) {
-      c.error(error1);
-    }
-  });
-  const ws = recordingWritableStream();
-  const writer = ws.getWriter();
-  const closePromise = writer.close();
-  writer.releaseLock();
-
-  return promise_rejects(t, error1, rs.pipeTo(ws), 'pipeTo must reject with the readable stream\'s error').then(() => {
-    assert_array_equals(rs.events, []);
-    assert_array_equals(ws.events, ['abort', error1], 'ws.events should contain abort for the time being');
-
-    return Promise.all([
-      promise_rejects(t, error1, rs.getReader().closed, 'the readable stream must be errored with error1'),
-      promise_rejects(t, new TypeError(), ws.getWriter().closed, 'the writable stream should be errored for the time being'),
-      promise_rejects(t, new TypeError(), closePromise, 'close() should reject for the time being')
-    ]);
-  });
-
-}, 'Piping from an errored readable stream to a closed writable stream');
-
-promise_test(t => {
-  const rs = recordingReadableStream({
-    start(c) {
-      c.close();
-    }
-  });
-  const ws = recordingWritableStream({
-    start(c) {
-      c.error(error1);
-    }
-  });
-
-  return promise_rejects(t, error1, rs.pipeTo(ws), 'pipeTo must reject with the writable stream\'s error').then(() => {
-    assert_array_equals(rs.events, []);
-    assert_array_equals(ws.events, []);
-
-    return Promise.all([
-      rs.getReader().closed,
-      promise_rejects(t, error1, ws.getWriter().closed, 'the writable stream must be errored with error1')
-    ]);
-  });
-
-}, 'Piping from a closed readable stream to an errored writable stream');
-
-promise_test(() => {
-  const rs = recordingReadableStream({
-    start(c) {
-      c.close();
-    }
-  });
-  const ws = recordingWritableStream();
-  const writer = ws.getWriter();
-  writer.close();
-  writer.releaseLock();
-
-  return rs.pipeTo(ws).then(() => {
-    assert_array_equals(rs.events, []);
-    assert_array_equals(ws.events, ['close']);
-
-    return Promise.all([
-      rs.getReader().closed,
-      ws.getWriter().closed
-    ]);
-  });
-
-}, 'Piping from a closed readable stream to a closed writable stream');
-
-done();