test: update wpt test for streams

PR-URL: #54129
Reviewed-By: Daeyeon Jeong <daeyeon.dev@gmail.com>
Reviewed-By: Antoine du Hamel <duhamelantoine1995@gmail.com>

Author: Nahee-Park

test/fixtures/wpt/README.md

@@ -27,7 +27,7 @@ Last update:
 - performance-timeline: https://github.com/web-platform-tests/wpt/tree/17ebc3aea0/performance-timeline
 - resource-timing: https://github.com/web-platform-tests/wpt/tree/22d38586d0/resource-timing
 - resources: https://github.com/web-platform-tests/wpt/tree/1e140d63ec/resources
-- streams: https://github.com/web-platform-tests/wpt/tree/9b03282a99/streams
+- streams: https://github.com/web-platform-tests/wpt/tree/2bd26e124c/streams
 - url: https://github.com/web-platform-tests/wpt/tree/6a39784534/url
 - user-timing: https://github.com/web-platform-tests/wpt/tree/5ae85bf826/user-timing
 - wasm/jsapi: https://github.com/web-platform-tests/wpt/tree/cde25e7e3c/wasm/jsapi

test/fixtures/wpt/streams/piping/abort.any.js

@@ -183,6 +183,46 @@ for (const reason of [null, undefined, error1]) {
 },`(reason: '${reason}') all pending writes should complete on abort`);
 }
 
+for(constreasonof[null,undefined,error1]){
+promise_test(asynct=>{
+letrejectPull;
+constpullPromise=newPromise((_,reject)=>{
+rejectPull=reject;
+});
+letrejectCancel;
+constcancelPromise=newPromise((_,reject)=>{
+rejectCancel=reject;
+});
+constrs=recordingReadableStream({
+asyncpull(){
+awaitPromise.race([
+pullPromise,
+cancelPromise,
+]);
+},
+cancel(reason){
+rejectCancel(reason);
+},
+});
+constws=newWritableStream();
+constabortController=newAbortController();
+constsignal=abortController.signal;
+constpipeToPromise=rs.pipeTo(ws,{ signal });
+pipeToPromise.catch(()=>{});// Prevent unhandled rejection.
+awaitdelay(0);
+abortController.abort(reason);
+rejectPull('should not catch pull rejection');
+awaitdelay(0);
+assert_equals(rs.eventsWithoutPulls.length,2,'cancel should have been called');
+assert_equals(rs.eventsWithoutPulls[0],'cancel','first event should be cancel');
+if(reason!==undefined){
+awaitpromise_rejects_exactly(t,reason,pipeToPromise,'pipeTo rejects with abort reason');
+}else{
+awaitpromise_rejects_dom(t,'AbortError',pipeToPromise,'pipeTo rejects with AbortError');
+}
+},`(reason: '${reason}') underlyingSource.cancel() should called when abort, even with pending pull`);
+}
+
 promise_test(t=>{
 constrs=newReadableStream({
 pull(controller){

test/fixtures/wpt/streams/piping/detached-context-crash.html

@@ -234,3 +234,28 @@ promise_test(() => {
 returnPromise.all([rs.cancel(),rs.getReader().closed]);
 
 },'ReadableStream cancellation: cancelling before start finishes should prevent pull() from being called');
+
+promise_test(async()=>{
+
+constevents=[];
+
+constpendingPromise=newPromise(()=>{});
+
+constrs=newReadableStream({
+pull(){
+events.push('pull');
+returnpendingPromise;
+},
+cancel(){
+events.push('cancel');
+}
+});
+
+constreader=rs.getReader();
+reader.read().catch(()=>{});// No await.
+awaitdelay(0);
+awaitPromise.all([reader.cancel(),reader.closed]);
+
+assert_array_equals(events,['pull','cancel'],'cancel should have been called');
+
+},'ReadableStream cancellation: underlyingSource.cancel() should called, even with pending pull');

test/fixtures/wpt/streams/readable-streams/cancel.any.js

@@ -51,44 +51,50 @@ const iterableFactories = [
 
 ['a sync iterable of values',()=>{
 constchunks=['a','b'];
-constit={
+constiterator={
 next(){
 return{
 done: chunks.length===0,
 value: chunks.shift()
 };
-},
-[Symbol.iterator]: ()=>it
+}
+};
+constiterable={
+[Symbol.iterator]: ()=>iterator
 };
-returnit;
+returniterable;
 }],
 
 ['a sync iterable of promises',()=>{
 constchunks=['a','b'];
-constit={
+constiterator={
 next(){
 returnchunks.length===0 ? {done: true} : {
 done: false,
 value: Promise.resolve(chunks.shift())
 };
-},
-[Symbol.iterator]: ()=>it
+}
+};
+constiterable={
+[Symbol.iterator]: ()=>iterator
 };
-returnit;
+returniterable;
 }],
 
 ['an async iterable',()=>{
 constchunks=['a','b'];
-constit={
+constasyncIterator={
 next(){
 returnPromise.resolve({
 done: chunks.length===0,
 value: chunks.shift()
 })
-},
-[Symbol.asyncIterator]: ()=>it
+}
+};
+constasyncIterable={
+[Symbol.asyncIterator]: ()=>asyncIterator
 };
-returnit;
+returnasyncIterable;
 }],
 
 ['a ReadableStream',()=>{
@@ -186,6 +192,18 @@ test(t => {
 assert_throws_exactly(theError,()=>ReadableStream.from(iterable),'from() should re-throw the error');
 },`ReadableStream.from ignores @@iterator if @@asyncIterator exists`);
 
+test(()=>{
+consttheError=newError('a unique string');
+constiterable={
+[Symbol.asyncIterator]: null,
+[Symbol.iterator](){
+throwtheError
+}
+};
+
+assert_throws_exactly(theError,()=>ReadableStream.from(iterable),'from() should re-throw the error');
+},`ReadableStream.from ignores a null @@asyncIterator`);
+
 promise_test(async()=>{
 
 constiterable={

test/fixtures/wpt/streams/readable-streams/from.any.js

@@ -68,7 +68,7 @@
 "path": "resources"
  },
 "streams": {
-"commit": "9b03282a99ef2314c1c2d5050a105a74a2940019",
+"commit": "2bd26e124cf17b2f0a25c150794d640b07b2a870",
 "path": "streams"
  },
 "url": {

test/fixtures/wpt/versions.json

@@ -16,6 +16,13 @@
 "readable-streams/cross-realm-crash.window.js": {
 "skip": "Browser-specific test"
  },
+"readable-streams/from.any.js": {
+"fail": {
+"expected": [
+"ReadableStream.from ignores a null @@asyncIterator"
+ ]
+ }
+ },
 "readable-streams/owning-type-message-port.any.js": {
 "fail": {
 "note": "Readable streams with type owning are not yet supported",
@@ -40,6 +47,9 @@
  ]
  }
  },
+"readable-streams/read-task-handling.window.js": {
+"skip": "Browser-specific test"
+ },
 "transferable/deserialize-error.window.js": {
 "skip": "Browser-specific test"
  },
@@ -56,8 +66,5 @@
  },
 "transform-streams/invalid-realm.tentative.window.js": {
 "skip": "Browser-specific test"
- },
-"readable-streams/read-task-handling.window.js": {
-"skip": "Browser-specific test"
  }
 }