Implementation of ReadableStream pipeTo and pipeThrough

third_party/WebKit/LayoutTests/http/tests/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 19 matching lines @@
     'constructor should throw when the type is null');
   assert_throws(new RangeError(), () => new ReadableStream({ type: '' }),
     'constructor should throw when the type is empty string');
   assert_throws(new RangeError(), () => new ReadableStream({ type: 'asdf' }),
     'constructor should throw when the type is asdf');
 
 }, 'ReadableStream can\'t be constructed with an invalid type');
 
 test(() => {
 
-  const methods = ['cancel', 'constructor', 'getReader', 'tee'];
+  const methods = ['cancel', 'constructor', 'getReader', 'pipeThrough', 'pipeTo', 'tee'];
   const properties = methods.concat(['locked']).sort();
 
   const rs = new ReadableStream();
   const proto = Object.getPrototypeOf(rs);
 
   assert_array_equals(Object.getOwnPropertyNames(proto).sort(), properties, 'should have all the correct methods');
 
   for (const m of methods) {
     const propDesc = Object.getOwnPropertyDescriptor(proto, m);
     assert_false(propDesc.enumerable, 'method should be non-enumerable');
@@ skipping 793 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();