Lines Matching refs:asIndexedPairs

6   // asIndexedPairs with a synchronous stream
7   const pairs = await Readable.from([1, 2, 3]).asIndexedPairs().toArray();
9   const empty = await Readable.from([]).asIndexedPairs().toArray();
14   // asIndexedPairs works an asynchronous streams
16   const pairs = await asyncFrom([1, 2, 3]).asIndexedPairs().toArray();
18   const empty = await asyncFrom([]).asIndexedPairs().toArray();
27   const pairs = await infinite().asIndexedPairs().take(3).toArray();
29   const empty = await infinite().asIndexedPairs().take(0).toArray();
38     const p = Readable.from([1, 2, 3]).asIndexedPairs({ signal }).toArray();
45     await Readable.from([1, 2, 3]).asIndexedPairs({ signal }).toArray();
51   throws(() => Readable.from([1]).asIndexedPairs(1), /ERR_INVALID_ARG_TYPE/);
52   throws(() => Readable.from([1]).asIndexedPairs({ signal: true }), /ERR_INVALID_ARG_TYPE/);