Lines Matching refs:Readable
5 Readable,
26 const streamReduce = await Readable.from(values)
34 const streamReduce = await Readable.from(values)
45 const six = await Readable.from([1, 2, 3]).reduce(async (p, c) => p + c, 0);
49 const six = await Readable.from([1, 2, 3]).reduce(async (p, c) => p + c);
55 assert.rejects(Readable.from([1, 2, 3, 4, 5, 6])
72 await Readable.from([1, 2, 3]).reduce(async (p, c) => {
87 const stream = Readable.from([1, 2, 3]);
104 const stream = Readable.from([1, 2, 3]);
122 assert.rejects(() => Readable.from([]).reduce(1), /TypeError/);
123 assert.rejects(() => Readable.from([]).reduce('5'), /TypeError/);
124 assert.rejects(() => Readable.from([]).reduce((x, y) => x + y, 0, 1), /ERR_INVALID_ARG_TYPE/);
125 assert.rejects(() => Readable.from([]).reduce((x, y) => x + y, 0, { signal: true }), /ERR_INVALID_ARG_TYPE/);
130 const result = Readable.from([1, 2, 3, 4, 5]).reduce(sum, 0);