Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(59)

Unified Diff: third_party/WebKit/LayoutTests/http/tests/streams/writable-streams/bad-underlying-sinks.js

Issue 2772293002: Update WritableStream to new standard version (Closed)
Patch Set: Changes from domenic@ review Created 3 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: third_party/WebKit/LayoutTests/http/tests/streams/writable-streams/bad-underlying-sinks.js
diff --git a/third_party/WebKit/LayoutTests/http/tests/streams/writable-streams/bad-underlying-sinks.js b/third_party/WebKit/LayoutTests/http/tests/streams/writable-streams/bad-underlying-sinks.js
deleted file mode 100644
index c519aad71cfe4b45cddedcc7a39b98a84b59f1aa..0000000000000000000000000000000000000000
--- a/third_party/WebKit/LayoutTests/http/tests/streams/writable-streams/bad-underlying-sinks.js
+++ /dev/null
@@ -1,215 +0,0 @@
-'use strict';
-
-if (self.importScripts) {
- self.importScripts('/resources/testharness.js');
- self.importScripts('../resources/test-utils.js');
- self.importScripts('../resources/recording-streams.js');
-}
-
-const error1 = new Error('error1');
-error1.name = 'error1';
-
-test(() => {
- assert_throws(error1, () => {
- new WritableStream({
- get start() {
- throw error1;
- }
- });
- }, 'constructor should throw same error as throwing start getter');
-
- assert_throws(error1, () => {
- new WritableStream({
- start() {
- throw error1;
- }
- });
- }, 'constructor should throw same error as throwing start method');
-
- assert_throws(new TypeError(), () => {
- new WritableStream({
- start: 'not a function or undefined'
- });
- }, 'constructor should throw TypeError when passed a non-function start property');
-
- assert_throws(new TypeError(), () => {
- new WritableStream({
- start: { apply() {} }
- });
- }, 'constructor should throw TypeError when passed a non-function start property with an .apply method');
-}, 'start: errors in start cause WritableStream constructor to throw');
-
-promise_test(t => {
-
- const ws = recordingWritableStream({
- close() {
- throw error1;
- }
- });
-
- const writer = ws.getWriter();
-
- return promise_rejects(t, error1, writer.close(), 'close() promise must reject with the thrown error')
- .then(() => promise_rejects(t, error1, writer.ready, 'ready promise must reject with the thrown error'))
- .then(() => promise_rejects(t, error1, writer.closed, 'closed promise must reject with the thrown error'))
- .then(() => {
- assert_array_equals(ws.events, ['close']);
- });
-
-}, 'close: throwing method should cause writer close() and ready to reject');
-
-promise_test(t => {
-
- const ws = recordingWritableStream({
- close() {
- return Promise.reject(error1);
- }
- });
-
- const writer = ws.getWriter();
-
- return promise_rejects(t, error1, writer.close(), 'close() promise must reject with the same error')
- .then(() => promise_rejects(t, error1, writer.ready, 'ready promise must reject with the same error'))
- .then(() => assert_array_equals(ws.events, ['close']));
-
-}, 'close: returning a rejected promise should cause writer close() and ready to reject');
-
-promise_test(t => {
- const ws = new WritableStream({
- get close() {
- throw error1;
- }
- });
-
- const writer = ws.getWriter();
-
- return promise_rejects(t, error1, writer.close(), 'close should reject with the thrown error');
-}, 'close: throwing getter should cause writer close() to reject');
-
-promise_test(t => {
- const ws = new WritableStream({
- get write() {
- throw error1;
- }
- });
-
- const writer = ws.getWriter();
-
- return promise_rejects(t, error1, writer.write('a'), 'write should reject with the thrown error')
- .then(() => promise_rejects(t, error1, writer.closed, 'closed should reject with the thrown error'));
-}, 'write: throwing getter should cause write() and closed to reject');
-
-promise_test(t => {
- const ws = new WritableStream({
- write() {
- throw error1;
- }
- });
-
- const writer = ws.getWriter();
-
- return promise_rejects(t, error1, writer.write('a'), 'write should reject with the thrown error')
- .then(() => promise_rejects(t, error1, writer.closed, 'closed should reject with the thrown error'));
-}, 'write: throwing method should cause write() and closed to reject');
-
-promise_test(t => {
-
- const startPromise = Promise.resolve();
- let rejectSinkWritePromise;
- const ws = recordingWritableStream({
- start() {
- return startPromise;
- },
- write() {
- return new Promise((r, reject) => {
- rejectSinkWritePromise = reject;
- });
- }
- });
-
- return startPromise.then(() => {
- const writer = ws.getWriter();
- const writePromise = writer.write('a');
- rejectSinkWritePromise(error1);
-
- return Promise.all([
- promise_rejects(t, error1, writePromise, 'writer write must reject with the same error'),
- promise_rejects(t, error1, writer.ready, 'ready promise must reject with the same error')
- ]);
- })
- .then(() => {
- assert_array_equals(ws.events, ['write', 'a']);
- });
-
-}, 'write: returning a promise that becomes rejected after the writer write() should cause writer write() and ready ' +
- 'to reject');
-
-promise_test(t => {
-
- const ws = recordingWritableStream({
- write() {
- if (ws.events.length === 2) {
- return delay(0);
- }
-
- return Promise.reject(error1);
- }
- });
-
- const writer = ws.getWriter();
-
- // Do not wait for this; we want to test the ready promise when the stream is "full" (desiredSize = 0), but if we wait
- // then the stream will transition back to "empty" (desiredSize = 1)
- writer.write('a');
- const readyPromise = writer.ready;
-
- return promise_rejects(t, error1, writer.write('b'), 'second write must reject with the same error').then(() => {
- assert_equals(writer.ready, readyPromise,
- 'the ready promise must not change, since the queue was full after the first write, so the pending one simply ' +
- 'transitioned');
- return promise_rejects(t, error1, writer.ready, 'ready promise must reject with the same error');
- })
- .then(() => assert_array_equals(ws.events, ['write', 'a', 'write', 'b']));
-
-}, 'write: returning a rejected promise (second write) should cause writer write() and ready to reject');
-
-promise_test(t => {
- const ws = new WritableStream({
- abort: { apply() {} }
- });
-
- return promise_rejects(t, new TypeError(), ws.abort(error1), 'abort should reject with TypeError').then(() => {
- const writer = ws.getWriter();
- return promise_rejects(t, new TypeError(), writer.closed, 'closed should reject with a TypeError');
- });
-}, 'abort: non-function abort method with .apply');
-
-promise_test(t => {
- const abortReason = new Error('different string');
- const ws = new WritableStream({
- get abort() {
- throw error1;
- }
- });
-
- const writer = ws.getWriter();
-
- return promise_rejects(t, error1, writer.abort(abortReason), 'abort should reject with the thrown error')
- .then(() => promise_rejects(t, new TypeError(), writer.closed, 'closed should reject with a TypeError'));
-}, 'abort: throwing getter should cause abort() and closed to reject');
-
-promise_test(t => {
- const abortReason = new Error('different string');
- const ws = new WritableStream({
- abort() {
- throw error1;
- }
- });
-
- const writer = ws.getWriter();
-
- return promise_rejects(t, error1, writer.abort(abortReason), 'abort should reject with the thrown error')
- .then(() => promise_rejects(t, new TypeError(), writer.closed, 'closed should reject with a TypeError'));
-}, 'abort: throwing method should cause abort() and closed to reject');
-
-done();

Powered by Google App Engine
This is Rietveld 408576698