| Index: third_party/WebKit/LayoutTests/http/tests/streams/readable-streams/bad-underlying-sources.js
|
| diff --git a/third_party/WebKit/LayoutTests/http/tests/streams/readable-streams/bad-underlying-sources.js b/third_party/WebKit/LayoutTests/http/tests/streams/readable-streams/bad-underlying-sources.js
|
| deleted file mode 100644
|
| index b95b54bc7fc9a6f1446b06b85a47efe9c2dc9611..0000000000000000000000000000000000000000
|
| --- a/third_party/WebKit/LayoutTests/http/tests/streams/readable-streams/bad-underlying-sources.js
|
| +++ /dev/null
|
| @@ -1,383 +0,0 @@
|
| -'use strict';
|
| -
|
| -if (self.importScripts) {
|
| - self.importScripts('/resources/testharness.js');
|
| -}
|
| -
|
| -
|
| -test(() => {
|
| -
|
| - const theError = new Error('a unique string');
|
| -
|
| - assert_throws(theError, () => {
|
| - new ReadableStream({
|
| - get start() {
|
| - throw theError;
|
| - }
|
| - });
|
| - }, 'constructing the stream should re-throw the error');
|
| -
|
| -}, 'Underlying source start: throwing getter');
|
| -
|
| -
|
| -test(() => {
|
| -
|
| - const theError = new Error('a unique string');
|
| -
|
| - assert_throws(theError, () => {
|
| - new ReadableStream({
|
| - start() {
|
| - throw theError;
|
| - }
|
| - });
|
| - }, 'constructing the stream should re-throw the error');
|
| -
|
| -}, 'Underlying source start: throwing method');
|
| -
|
| -
|
| -promise_test(t => {
|
| -
|
| - const theError = new Error('a unique string');
|
| - const rs = new ReadableStream({
|
| - get pull() {
|
| - throw theError;
|
| - }
|
| - });
|
| -
|
| - return promise_rejects(t, theError, rs.getReader().closed);
|
| -
|
| -}, 'Underlying source: throwing pull getter (initial pull)');
|
| -
|
| -
|
| -promise_test(t => {
|
| -
|
| - const theError = new Error('a unique string');
|
| - const rs = new ReadableStream({
|
| - pull() {
|
| - throw theError;
|
| - }
|
| - });
|
| -
|
| - return promise_rejects(t, theError, rs.getReader().closed);
|
| -
|
| -}, 'Underlying source: throwing pull method (initial pull)');
|
| -
|
| -
|
| -promise_test(t => {
|
| -
|
| - const theError = new Error('a unique string');
|
| -
|
| - let counter = 0;
|
| - const rs = new ReadableStream({
|
| - get pull() {
|
| - ++counter;
|
| - if (counter === 1) {
|
| - return c => c.enqueue('a');
|
| - }
|
| -
|
| - throw theError;
|
| - }
|
| - });
|
| - const reader = rs.getReader();
|
| -
|
| - return Promise.all([
|
| - reader.read().then(r => {
|
| - assert_object_equals(r, { value: 'a', done: false }, 'the chunk read should be correct');
|
| - }),
|
| - promise_rejects(t, theError, reader.closed)
|
| - ]);
|
| -
|
| -}, 'Underlying source pull: throwing getter (second pull)');
|
| -
|
| -
|
| -promise_test(t => {
|
| -
|
| - const theError = new Error('a unique string');
|
| -
|
| - let counter = 0;
|
| - const rs = new ReadableStream({
|
| - pull(c) {
|
| - ++counter;
|
| - if (counter === 1) {
|
| - c.enqueue('a');
|
| - return;
|
| - }
|
| -
|
| - throw theError;
|
| - }
|
| - });
|
| - const reader = rs.getReader();
|
| -
|
| - return Promise.all([
|
| - reader.read().then(r => {
|
| - assert_object_equals(r, { value: 'a', done: false }, 'the chunk read should be correct');
|
| - }),
|
| - promise_rejects(t, theError, reader.closed)
|
| - ]);
|
| -
|
| -}, 'Underlying source pull: throwing method (second pull)');
|
| -
|
| -promise_test(t => {
|
| -
|
| - const theError = new Error('a unique string');
|
| - const rs = new ReadableStream({
|
| - get cancel() {
|
| - throw theError;
|
| - }
|
| - });
|
| -
|
| - return promise_rejects(t, theError, rs.cancel());
|
| -
|
| -}, 'Underlying source cancel: throwing getter');
|
| -
|
| -promise_test(t => {
|
| -
|
| - const theError = new Error('a unique string');
|
| - const rs = new ReadableStream({
|
| - cancel() {
|
| - throw theError;
|
| - }
|
| - });
|
| -
|
| - return promise_rejects(t, theError, rs.cancel());
|
| -
|
| -}, 'Underlying source cancel: throwing method');
|
| -
|
| -promise_test(() => {
|
| -
|
| - let controller;
|
| - const rs = new ReadableStream({
|
| - start(c) {
|
| - controller = c;
|
| - }
|
| - });
|
| -
|
| - rs.cancel();
|
| - 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 throw');
|
| -
|
| -promise_test(() => {
|
| -
|
| - let controller;
|
| - const rs = new ReadableStream({
|
| - start(c) {
|
| - c.enqueue('a');
|
| - c.enqueue('b');
|
| - controller = c;
|
| - }
|
| - });
|
| -
|
| - rs.cancel();
|
| - 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 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(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({
|
| - start(c) {
|
| - c.close();
|
| - assert_throws(new TypeError(), () => c.close(), 'second call to close should throw a TypeError');
|
| - }
|
| - }).getReader().closed;
|
| -
|
| -}, 'Underlying source: calling close twice on an empty stream should throw the second time');
|
| -
|
| -promise_test(() => {
|
| -
|
| - let startCalled = false;
|
| - let readCalled = false;
|
| - const reader = new ReadableStream({
|
| - start(c) {
|
| - c.enqueue('a');
|
| - c.close();
|
| - assert_throws(new TypeError(), () => c.close(), 'second call to close should throw a TypeError');
|
| - startCalled = true;
|
| - }
|
| - }).getReader();
|
| -
|
| - return Promise.all([
|
| - reader.read().then(r => {
|
| - assert_object_equals(r, { value: 'a', done: false }, 'read() should read the enqueued chunk');
|
| - readCalled = true;
|
| - }),
|
| - reader.closed.then(() => {
|
| - assert_true(startCalled);
|
| - assert_true(readCalled);
|
| - })
|
| - ]);
|
| -
|
| -}, 'Underlying source: calling close twice on a non-empty stream should throw the second time');
|
| -
|
| -promise_test(() => {
|
| -
|
| - let controller;
|
| - let startCalled = false;
|
| - const rs = new ReadableStream({
|
| - start(c) {
|
| - controller = c;
|
| - startCalled = true;
|
| - }
|
| - });
|
| -
|
| - rs.cancel();
|
| - 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 throw');
|
| -
|
| -promise_test(() => {
|
| -
|
| - let controller;
|
| - let startCalled = false;
|
| - const rs = new ReadableStream({
|
| - start(c) {
|
| - controller = c;
|
| - c.enqueue('a');
|
| - startCalled = true;
|
| - }
|
| - });
|
| -
|
| - rs.cancel();
|
| - 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 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');
|
| - startCalled = true;
|
| - }
|
| - }).getReader().closed;
|
| -
|
| - return closed.catch(e => {
|
| - assert_true(startCalled);
|
| - assert_equals(e, theError, 'closed should reject with the error');
|
| - });
|
| -
|
| -}, 'Underlying source: calling close after error 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.error(), 'second call to error should throw a TypeError');
|
| - startCalled = true;
|
| - }
|
| - }).getReader().closed;
|
| -
|
| - return closed.catch(e => {
|
| - assert_true(startCalled);
|
| - assert_equals(e, theError, 'closed should reject with the error');
|
| - });
|
| -
|
| -}, 'Underlying source: calling error twice should throw the second time');
|
| -
|
| -promise_test(() => {
|
| -
|
| - let startCalled = false;
|
| -
|
| - const closed = new ReadableStream({
|
| - start(c) {
|
| - c.close();
|
| - assert_throws(new TypeError(), () => c.error(), 'second call to error should throw a TypeError');
|
| - startCalled = true;
|
| - }
|
| - }).getReader().closed;
|
| -
|
| - return closed.then(() => assert_true(startCalled));
|
| -
|
| -}, 'Underlying source: calling error after close should throw');
|
| -
|
| -promise_test(() => {
|
| -
|
| - let startCalled = false;
|
| - const firstError = new Error('1');
|
| - const secondError = new Error('2');
|
| -
|
| - const closed = new ReadableStream({
|
| - start(c) {
|
| - c.error(firstError);
|
| - startCalled = true;
|
| - return Promise.reject(secondError);
|
| - }
|
| - }).getReader().closed;
|
| -
|
| - 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 start should cause the stream to error ' +
|
| - 'with the first error');
|
| -
|
| -promise_test(() => {
|
| -
|
| - let startCalled = false;
|
| - const firstError = new Error('1');
|
| - const secondError = new Error('2');
|
| -
|
| - const closed = new ReadableStream({
|
| - pull(c) {
|
| - c.error(firstError);
|
| - startCalled = true;
|
| - return Promise.reject(secondError);
|
| - }
|
| - }).getReader().closed;
|
| -
|
| - 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();
|
|
|