()
| 45 | |
| 46 | async function testMultiBatchAsync() { |
| 47 | async function* gen() { |
| 48 | for (let i = 0; i < 5; i++) { |
| 49 | const batch = []; |
| 50 | for (let j = 0; j < 3; j++) { |
| 51 | batch.push(Buffer.from(`${i}-${j} `)); |
| 52 | } |
| 53 | yield batch; |
| 54 | } |
| 55 | } |
| 56 | |
| 57 | const readable = toReadable(gen()); |
| 58 | const result = await collect(readable); |
no test coverage detected