Lines Matching defs:stream
32 const stream = Readable.from([1, 2, 3, 4, 5]).map((x) => x + x); constant
40 const stream = Readable.from([1, 2, 3, 4, 5]).map(async (x) => { constant
51 const stream = Readable.from([1, 2, 3, 4, 5]).map(async (x) => { constant
61 const stream = Readable.from(async function* () { constant
104 const stream = source.map(async ([x]) => { constant
117 const stream = Readable.from([1, 2, 3, 4, 5]).map(async (x) => { constant
131 const stream = Readable.from([1, 2, 3, 4, 5]).map((x) => { constant
146 const stream = Readable.from([1, 2, 3, 4, 5]).map(async (x) => { constant
162 const stream = range.map(common.mustCall(async (_, { signal }) => { constant
182 const stream = Readable.from([1, 2]).map(async (item, { signal }) => { constant
203 const stream = raw.map(async (item) => { constant
250 const stream = raw.map(async (item) => { constant
298 const stream = raw.map(async (item) => { constant
322 const stream = raw constant
358 const stream = Readable.from([1, 2, 3, 4, 5]).map((x) => x); constant