Import wpt@503f5b5f78ec4e87d144f78609f363f0ed0ea8db

third_party/WebKit/LayoutTests/external/wpt/streams/readable-streams/general.js

 'use strict';
 
 if (self.importScripts) {
   self.importScripts('../resources/test-utils.js');
   self.importScripts('../resources/rs-utils.js');
   self.importScripts('/resources/testharness.js');
 }
 
 test(() => {
 
@@ skipping 715 matching lines @@
     rs.cancel();
     assert_equals(startCalled, 1);
     assert_equals(pullCalled, 1);
     assert_equals(cancelCalled, 1);
     return rs.getReader().closed;
   });
 
 }, 'ReadableStream: should call underlying source methods as methods');
 
 test(() => {
+  const rs = new ReadableStream({
+    start(c) {
+      assert_equals(c.desiredSize, 10, 'desiredSize must start at highWaterMark');
+      c.close();
+      assert_equals(c.desiredSize, 0, 'after closing, desiredSize must be 0');
+    }
+  }, {
+    highWaterMark: 10
+  });
+}, 'ReadableStream: desiredSize when closed');
+
+test(() => {
+  const rs = new ReadableStream({
+    start(c) {
+      assert_equals(c.desiredSize, 10, 'desiredSize must start at highWaterMark');
+      c.error();
+      assert_equals(c.desiredSize, null, 'after erroring, desiredSize must be null');
+    }
+  }, {
+    highWaterMark: 10
+  });
+}, 'ReadableStream: desiredSize when errored');
+
+test(() => {
 
   let startCalled = false;
   new ReadableStream({
     start(c) {
       assert_equals(c.desiredSize, 1);
       c.enqueue('a');
       assert_equals(c.desiredSize, 0);
       c.enqueue('b');
       assert_equals(c.desiredSize, -1);
       c.enqueue('c');
@@ skipping 104 matching lines @@
   const rs = sequentialReadableStream(10, { async: true });
 
   return readableStreamToArray(rs).then(chunks => {
     assert_true(rs.source.closed, 'source should be closed after all chunks are read');
     assert_array_equals(chunks, [1, 2, 3, 4, 5, 6, 7, 8, 9, 10], 'the expected 10 chunks should be read');
   });
 
 }, 'ReadableStream integration test: adapting an async pull source');
 
 done();