Import wpt@767dc2a4f049c761bd146d61de2ea860a895a624

third_party/WebKit/LayoutTests/external/wpt/streams/piping/general.js

 'use strict';
 
 if (self.importScripts) {
   self.importScripts('/resources/testharness.js');
   self.importScripts('../resources/test-utils.js');
   self.importScripts('../resources/recording-streams.js');
 }
 
 test(() => {
 
@@ skipping 143 matching lines @@
 
 }, 'Piping from a ReadableStream for which a chunk becomes asynchronously readable after the pipeTo');
 
 for (const preventAbort of [true, false]) {
   promise_test(t => {
 
     const rs = new ReadableStream({
       pull() {
         return Promise.reject(undefined);
       }
-    }, { preventAbort });
+    });
 
-    return rs.pipeTo(new WritableStream()).then(
+    return rs.pipeTo(new WritableStream(), { preventAbort }).then(
         () => assert_unreached('pipeTo promise should be rejected'),
         value => assert_equals(value, undefined, 'rejection value should be undefined'));
 
   }, `an undefined rejection from pull should cause pipeTo() to reject when preventAbort is ${preventAbort}`);
 }
 
 for (const preventCancel of [true, false]) {
   promise_test(t => {
 
     const rs = new ReadableStream({
       pull(controller) {
         controller.enqueue(0);
       }
-    }, { preventCancel });
+    });
 
     const ws = new WritableStream({
       write() {
         return Promise.reject(undefined);
       }
     });
 
-    return rs.pipeTo(ws).then(
+    return rs.pipeTo(ws, { preventCancel }).then(
          () => assert_unreached('pipeTo promise should be rejected'),
         value => assert_equals(value, undefined, 'rejection value should be undefined'));
 
   }, `an undefined rejection from write should cause pipeTo() to reject when preventCancel is ${preventCancel}`);
 }
 
 done();