| 36 | let teeResult; |
| 37 | |
| 38 | function main({ n, kind }) { |
| 39 | switch (kind) { |
| 40 | case 'ReadableStream': |
| 41 | globalThis.gc(); |
| 42 | bench.start(); |
| 43 | for (let i = 0; i < n; ++i) |
| 44 | readableStream = new ReadableStream(); |
| 45 | bench.end(n); |
| 46 | |
| 47 | // Avoid V8 deadcode (elimination) |
| 48 | assert.ok(readableStream); |
| 49 | break; |
| 50 | case 'WritableStream': |
| 51 | globalThis.gc(); |
| 52 | bench.start(); |
| 53 | for (let i = 0; i < n; ++i) |
| 54 | writableStream = new WritableStream(); |
| 55 | bench.end(n); |
| 56 | |
| 57 | // Avoid V8 deadcode (elimination) |
| 58 | assert.ok(writableStream); |
| 59 | break; |
| 60 | case 'TransformStream': |
| 61 | globalThis.gc(); |
| 62 | bench.start(); |
| 63 | for (let i = 0; i < n; ++i) |
| 64 | transformStream = new TransformStream(); |
| 65 | bench.end(n); |
| 66 | |
| 67 | // Avoid V8 deadcode (elimination) |
| 68 | assert.ok(transformStream); |
| 69 | break; |
| 70 | case 'ReadableStreamDefaultReader': { |
| 71 | const readers = Array.from({ length: n }, () => new ReadableStream()); |
| 72 | |
| 73 | globalThis.gc(); |
| 74 | bench.start(); |
| 75 | for (let i = 0; i < n; ++i) |
| 76 | readableStreamDefaultReader = new ReadableStreamDefaultReader(readers[i]); |
| 77 | bench.end(n); |
| 78 | |
| 79 | // Avoid V8 deadcode (elimination) |
| 80 | assert.ok(readableStreamDefaultReader); |
| 81 | break; |
| 82 | } |
| 83 | case 'ReadableStreamBYOBReader': { |
| 84 | const readers = Array.from({ length: n }, () => new ReadableStream({ type: 'bytes' })); |
| 85 | |
| 86 | globalThis.gc(); |
| 87 | bench.start(); |
| 88 | for (let i = 0; i < n; ++i) |
| 89 | readableStreamBYOBReader = new ReadableStreamBYOBReader(readers[i]); |
| 90 | bench.end(n); |
| 91 | |
| 92 | // Avoid V8 deadcode (elimination) |
| 93 | assert.ok(readableStreamBYOBReader); |
| 94 | break; |
| 95 | } |