Lines Matching refs:Readable
5 Readable,
32 const stream = Readable.from([1, 2, 3, 4, 5]).map((x) => x + x);
40 const stream = Readable.from([1, 2, 3, 4, 5]).map(async (x) => {
51 const stream = Readable.from([1, 2, 3, 4, 5]).map(async (x) => {
61 const stream = Readable.from(async function* () {
77 const stream = new Readable({
96 const source = new Readable({
117 const stream = Readable.from([1, 2, 3, 4, 5]).map(async (x) => {
131 const stream = Readable.from([1, 2, 3, 4, 5]).map((x) => {
146 const stream = Readable.from([1, 2, 3, 4, 5]).map(async (x) => {
161 const range = Readable.from([1, 2, 3, 4, 5]);
182 const stream = Readable.from([1, 2]).map(async (item, { signal }) => {
202 const raw = Readable.from([2, 0, 1, 3]);
226 const raw = Readable.from(input);
274 const raw = Readable.from(input);
320 const raw = Readable.from([0, 1, 2]);
346 assert.throws(() => Readable.from([1]).map(1), /ERR_INVALID_ARG_TYPE/);
347 assert.throws(() => Readable.from([1]).map((x) => x, {
350 assert.throws(() => Readable.from([1]).map((x) => x, {
353 assert.throws(() => Readable.from([1]).map((x) => x, 1), /ERR_INVALID_ARG_TYPE/);
354 assert.throws(() => Readable.from([1]).map((x) => x, { signal: true }), /ERR_INVALID_ARG_TYPE/);
357 // Test result is a Readable
358 const stream = Readable.from([1, 2, 3, 4, 5]).map((x) => x);