Lines Matching refs:item
68 for await (const item of stream) {
69 assert.strictEqual(item, 2);
88 for await (const item of stream) {
89 assert.strictEqual(item, result.shift());
109 for await (const item of stream) {
110 assert.strictEqual(item, result.shift());
168 for await (const item of stream) {
169 assert.fail('should not reach here, got ' + item);
182 const stream = Readable.from([1, 2]).map(async (item, { signal }) => {
183 await setTimeout(10 - item, { signal });
184 return item;
189 for await (const item of stream) {
190 assert.strictEqual(item, expected.shift());
203 const stream = raw.map(async (item) => {
204 const [promise, resolve] = promises[item];
208 finishOrder.push(item);
209 return item;
250 const stream = raw.map(async (item) => {
251 const [promise, resolve] = promises[item];
255 finishOrder.push(item);
256 return item;
298 const stream = raw.map(async (item) => {
299 const [promise, resolve] = promises[item];
303 finishOrder.push(item);
304 return item;
316 // Where there is a delay between the first and the next item it should not wait for filled queue
323 .map(async (item) => {
324 if (item !== 0) {
325 await promises[item][0];
328 return item;
330 .map((item) => {
336 return item;