| 52 | } |
| 53 | |
| 54 | function benchWebStream(type, n) { |
| 55 | let tmp; |
| 56 | bench.start(); |
| 57 | switch (type) { |
| 58 | case 'readable': |
| 59 | for (let i = 0; i < n; i++) tmp = new ReadableStream({ pull() {} }); |
| 60 | break; |
| 61 | case 'writable': |
| 62 | for (let i = 0; i < n; i++) tmp = new WritableStream({ write() {} }); |
| 63 | break; |
| 64 | case 'transform': |
| 65 | for (let i = 0; i < n; i++) tmp = new TransformStream({ |
| 66 | transform(c, controller) { controller.enqueue(c); }, |
| 67 | }); |
| 68 | break; |
| 69 | case 'pair': { |
| 70 | // TransformStream gives a readable+writable pair |
| 71 | for (let i = 0; i < n; i++) tmp = new TransformStream(); |
| 72 | break; |
| 73 | } |
| 74 | } |
| 75 | bench.end(n); |
| 76 | ok(tmp !== undefined); |
| 77 | } |
| 78 | |
| 79 | function benchIter(type, n) { |
| 80 | const { push, from, duplex } = require('stream/iter'); |