(type, n)
| 77 | } |
| 78 | |
| 79 | function benchIter(type, n) { |
| 80 | const { push, from, duplex } = require('stream/iter'); |
| 81 | let tmp; |
| 82 | |
| 83 | bench.start(); |
| 84 | switch (type) { |
| 85 | case 'readable': |
| 86 | for (let i = 0; i < n; i++) tmp = from('x'); |
| 87 | break; |
| 88 | case 'writable': |
| 89 | // push() creates a writer+readable pair |
| 90 | for (let i = 0; i < n; i++) tmp = push(); |
| 91 | break; |
| 92 | case 'pair': |
| 93 | // duplex() creates a bidirectional channel pair |
| 94 | for (let i = 0; i < n; i++) tmp = duplex(); |
| 95 | break; |
| 96 | } |
| 97 | bench.end(n); |
| 98 | ok(tmp !== undefined); |
| 99 | } |