Lines Matching refs:rs
10 const rs = new ReadableStream({ constant
16 finished(rs, common.mustSucceed());
19 for await (const chunk of rs) {
28 const rs = new ReadableStream({ constant
34 finished(rs, common.mustCall((err) => {
40 const rs = new ReadableStream({ constant
46 finished(rs, common.mustCall((err) => {
52 const rs = new ReadableStream({ constant
61 for await (const chunk of rs) {
67 finishedPromise(rs).then(common.mustSucceed());
73 const rs = new ReadableStream({ constant
79 finishedPromise(rs).then(common.mustNotCall()).catch(common.mustCall((err) => {
85 const rs = new ReadableStream({ constant
91 finishedPromise(rs).then(common.mustNotCall()).catch(common.mustCall((err) => {
97 const rs = new ReadableStream({ constant
104 const { 0: s1, 1: s2 } = rs.tee();
124 const rs = new ReadableStream({ constant
130 const { 0: s1, 1: s2 } = rs.tee();
142 const rs = new ReadableStream({ constant
149 finished(rs, common.mustSucceed());
151 rs.cancel();
239 const rs = new ReadableStream({ constant
242 finished(rs, { signal }, common.mustCall((err) => {
252 const rs = new ReadableStream({ constant
255 finished(rs, { signal }, common.mustCall((err) => {
267 const rs = new ReadableStream({ constant
271 finished(rs, { signal }, common.mustCall((err) => {
281 const rs = new ReadableStream({ constant
287 finished(rs, { signal }, common.mustSucceed());
289 rs.getReader().read().then(common.mustCall((chunk) => {
300 const rs = new ReadableStream({
304 await finishedPromise(rs, { signal });
315 const rs = new ReadableStream({
318 await finishedPromise(rs, { signal });