Reflect recent spec changes to V8 Extra ReadableStream impl

third_party/WebKit/LayoutTests/http/tests/streams/readable-streams/bad-underlying-sources.js

 'use strict';
 
 if (self.importScripts) {
   self.importScripts('/resources/testharness.js');
 }
 
 
 test(() => {
 
   const theError = new Error('a unique string');
@@ skipping 135 matching lines @@
 promise_test(() => {
 
   let controller;
   const rs = new ReadableStream({
     start(c) {
       controller = c;
     }
   });
 
   rs.cancel();
-  controller.enqueue('a'); // Calling enqueue after canceling should not throw anything.
+  assert_throws(new TypeError, () => controller.enqueue('a'), 'Calling enqueue after canceling should throw');
 
   return rs.getReader().closed;
 
-}, 'Underlying source: calling enqueue on an empty canceled stream should not throw');
+}, 'Underlying source: calling enqueue on an empty canceled stream should throw');
 
 promise_test(() => {
 
   let controller;
   const rs = new ReadableStream({
     start(c) {
       c.enqueue('a');
       c.enqueue('b');
       controller = c;
     }
   });
 
   rs.cancel();
-  controller.enqueue('c'); // Calling enqueue after canceling should not throw anything.
+  assert_throws(new TypeError, () => controller.enqueue('c'), 'Calling enqueue after canceling should throw');
 
   return rs.getReader().closed;
 
-}, 'Underlying source: calling enqueue on a non-empty canceled stream should not throw');
+}, 'Underlying source: calling enqueue on a non-empty canceled stream should throw');
 
 promise_test(() => {
 
   return new ReadableStream({
     start(c) {
       c.close();
       assert_throws(new TypeError(), () => c.enqueue('a'), 'call to enqueue should throw a TypeError');
     }
   }).getReader().closed;
 
 }, 'Underlying source: calling enqueue on a closed stream should throw');
 
 promise_test(t => {
 
   const theError = new Error('boo');
   const closed = new ReadableStream({
     start(c) {
       c.error(theError);
-      assert_throws(theError, () => c.enqueue('a'), 'call to enqueue should throw the error');
+      assert_throws(new TypeError(), () => c.enqueue('a'), 'call to enqueue should throw the error');
     }
   }).getReader().closed;
 
   return promise_rejects(t, theError, closed);
 
 }, 'Underlying source: calling enqueue on an errored stream should throw');
 
 promise_test(() => {
 
   return new ReadableStream({
@@ skipping 36 matching lines @@
   let controller;
   let startCalled = false;
   const rs = new ReadableStream({
     start(c) {
       controller = c;
       startCalled = true;
     }
   });
 
   rs.cancel();
-  controller.close(); // Calling close after canceling should not throw anything.
+  assert_throws(new TypeError(), () => controller.close(), 'Calling close after canceling should throw');
 
   return rs.getReader().closed.then(() => {
     assert_true(startCalled);
   });
 
-}, 'Underlying source: calling close on an empty canceled stream should not throw');
+}, 'Underlying source: calling close on an empty canceled stream should throw');
 
 promise_test(() => {
 
   let controller;
   let startCalled = false;
   const rs = new ReadableStream({
     start(c) {
       controller = c;
       c.enqueue('a');
       startCalled = true;
     }
   });
 
   rs.cancel();
-  controller.close(); // Calling close after canceling should not throw anything.
+  assert_throws(new TypeError(), () => controller.close(), 'Calling close after canceling should throw');
 
   return rs.getReader().closed.then(() => {
     assert_true(startCalled);
   });
 
-}, 'Underlying source: calling close on a non-empty canceled stream should not throw');
+}, 'Underlying source: calling close on a non-empty canceled stream should throw');
 
 promise_test(() => {
 
   const theError = new Error('boo');
   let startCalled = false;
 
   const closed = new ReadableStream({
     start(c) {
       c.error(theError);
       assert_throws(new TypeError(), () => c.close(), 'call to close should throw a TypeError');
@@ skipping 82 matching lines @@
 
   return closed.catch(e => {
     assert_true(startCalled);
     assert_equals(e, firstError, 'closed should reject with the first error');
   });
 
 }, 'Underlying source: calling error and returning a rejected promise from pull should cause the stream to error ' +
    'with the first error');
 
 done();