Index: third_party/WebKit/LayoutTests/http/tests/streams/writable-streams/close.js |
diff --git a/third_party/WebKit/LayoutTests/http/tests/streams/writable-streams/close.js b/third_party/WebKit/LayoutTests/http/tests/streams/writable-streams/close.js |
deleted file mode 100644 |
index 5c83a5e12839d13460241731c39e467de2a7a399..0000000000000000000000000000000000000000 |
--- a/third_party/WebKit/LayoutTests/http/tests/streams/writable-streams/close.js |
+++ /dev/null |
@@ -1,216 +0,0 @@ |
-'use strict'; |
- |
-if (self.importScripts) { |
- self.importScripts('/resources/testharness.js'); |
- self.importScripts('../resources/test-utils.js'); |
- self.importScripts('../resources/recording-streams.js'); |
-} |
- |
-promise_test(() => { |
- const ws = new WritableStream({ |
- close() { |
- return 'Hello'; |
- } |
- }); |
- |
- const writer = ws.getWriter(); |
- |
- const closePromise = writer.close(); |
- return closePromise.then(value => assert_equals(value, undefined, 'fulfillment value must be undefined')); |
-}, 'fulfillment value of ws.close() call must be undefined even if the underlying sink returns a non-undefined ' + |
- 'value'); |
- |
-promise_test(t => { |
- const passedError = new Error('error me'); |
- let controller; |
- const ws = new WritableStream({ |
- close(c) { |
- controller = c; |
- return delay(50); |
- } |
- }); |
- |
- const writer = ws.getWriter(); |
- |
- return Promise.all([ |
- writer.close(), |
- delay(10).then(() => controller.error(passedError)), |
- promise_rejects(t, passedError, writer.closed, |
- 'closed promise should be rejected with the passed error'), |
- delay(70).then(() => promise_rejects(t, passedError, writer.closed, 'closed should stay rejected')) |
- ]); |
-}, 'when sink calls error asynchronously while closing, the stream should become errored'); |
- |
-promise_test(t => { |
- const passedError = new Error('error me'); |
- const ws = new WritableStream({ |
- close(controller) { |
- controller.error(passedError); |
- } |
- }); |
- |
- const writer = ws.getWriter(); |
- |
- return writer.close().then(() => promise_rejects(t, passedError, writer.closed, 'closed should stay rejected')); |
-}, 'when sink calls error synchronously while closing, the stream should become errored'); |
- |
-promise_test(() => { |
- const ws = recordingWritableStream(); |
- |
- const writer = ws.getWriter(); |
- |
- return writer.ready.then(() => { |
- assert_equals(writer.desiredSize, 1, 'desiredSize should be 1'); |
- |
- writer.close(); |
- assert_equals(writer.desiredSize, 1, 'desiredSize should be still 1'); |
- |
- return writer.ready.then(v => { |
- assert_equals(v, undefined, 'ready promise should be fulfilled with undefined'); |
- assert_array_equals(ws.events, ['close'], 'write and abort should not be called'); |
- }); |
- }); |
-}, 'when close is called on a WritableStream in writable state, ready should return a fulfilled promise'); |
- |
-promise_test(() => { |
- const ws = recordingWritableStream({ |
- write() { |
- return new Promise(() => {}); |
- } |
- }); |
- |
- const writer = ws.getWriter(); |
- |
- return writer.ready.then(() => { |
- writer.write('a'); |
- |
- assert_equals(writer.desiredSize, 0, 'desiredSize should be 0'); |
- |
- let calledClose = false; |
- return Promise.all([ |
- writer.ready.then(v => { |
- assert_equals(v, undefined, 'ready promise should be fulfilled with undefined'); |
- assert_true(calledClose, 'ready should not be fulfilled before writer.close() is called'); |
- assert_array_equals(ws.events, ['write', 'a'], 'sink abort() should not be called'); |
- }), |
- flushAsyncEvents().then(() => { |
- writer.close(); |
- calledClose = true; |
- }) |
- ]); |
- }); |
-}, 'when close is called on a WritableStream in waiting state, ready promise should be fulfilled'); |
- |
-promise_test(() => { |
- let asyncCloseFinished = false; |
- const ws = recordingWritableStream({ |
- close() { |
- return flushAsyncEvents().then(() => { |
- asyncCloseFinished = true; |
- }); |
- } |
- }); |
- |
- const writer = ws.getWriter(); |
- return writer.ready.then(() => { |
- writer.write('a'); |
- |
- writer.close(); |
- |
- return writer.ready.then(v => { |
- assert_false(asyncCloseFinished, 'ready promise should be fulfilled before async close completes'); |
- assert_equals(v, undefined, 'ready promise should be fulfilled with undefined'); |
- assert_array_equals(ws.events, ['write', 'a', 'close'], 'sink abort() should not be called'); |
- }); |
- }); |
-}, 'when close is called on a WritableStream in waiting state, ready should be fulfilled immediately even if close ' + |
- 'takes a long time'); |
- |
-promise_test(t => { |
- const rejection = { name: 'letter' }; |
- const ws = new WritableStream({ |
- close() { |
- return { |
- then(onFulfilled, onRejected) { onRejected(rejection); } |
- }; |
- } |
- }); |
- return promise_rejects(t, rejection, ws.getWriter().close(), 'close() should return a rejection'); |
-}, 'returning a thenable from close() should work'); |
- |
-promise_test(t => { |
- const ws = new WritableStream(); |
- const writer = ws.getWriter(); |
- return writer.ready.then(() => { |
- const closePromise = writer.close(); |
- const closedPromise = writer.closed; |
- writer.releaseLock(); |
- return Promise.all([ |
- closePromise, |
- promise_rejects(t, new TypeError(), closedPromise, '.closed promise should be rejected') |
- ]); |
- }); |
-}, 'releaseLock() should not change the result of sync close()'); |
- |
-promise_test(t => { |
- const ws = new WritableStream({ |
- close() { |
- return flushAsyncEvents(); |
- } |
- }); |
- const writer = ws.getWriter(); |
- return writer.ready.then(() => { |
- const closePromise = writer.close(); |
- const closedPromise = writer.closed; |
- writer.releaseLock(); |
- return Promise.all([ |
- closePromise, |
- promise_rejects(t, new TypeError(), closedPromise, '.closed promise should be rejected') |
- ]); |
- }); |
-}, 'releaseLock() should not change the result of async close()'); |
- |
-promise_test(() => { |
- let resolveClose; |
- const ws = new WritableStream({ |
- close() { |
- const promise = new Promise(resolve => { |
- resolveClose = resolve; |
- }); |
- return promise; |
- } |
- }); |
- const writer = ws.getWriter(); |
- const closePromise = writer.close(); |
- writer.releaseLock(); |
- return delay(0).then(() => { |
- resolveClose(); |
- return closePromise.then(() => { |
- assert_equals(ws.getWriter().desiredSize, 0, 'desiredSize should be 0'); |
- }); |
- }); |
-}, 'close() should set state to CLOSED even if writer has detached'); |
- |
-promise_test(() => { |
- let resolveClose; |
- const ws = new WritableStream({ |
- close() { |
- const promise = new Promise(resolve => { |
- resolveClose = resolve; |
- }); |
- return promise; |
- } |
- }); |
- const writer = ws.getWriter(); |
- writer.close(); |
- writer.releaseLock(); |
- return delay(0).then(() => { |
- const abortingWriter = ws.getWriter(); |
- const abortPromise = abortingWriter.abort(); |
- abortingWriter.releaseLock(); |
- resolveClose(); |
- return abortPromise; |
- }); |
-}, 'the promise returned by async abort during close should resolve'); |
- |
-done(); |