'first'

fcs

2025-04-10 0163870d662dc5b7d69ceff977490ede594f7d82

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
'use strict';
const AggregateError = require('aggregate-error');
 
module.exports = (iterable, opts) => new Promise((resolve, reject) => {
    opts = Object.assign({}, opts);
 
    if (!Number.isFinite(opts.count)) {
        throw new TypeError(`Expected a finite number, got ${typeof opts.count}`);
    }
 
    const values = [];
    const errors = [];
    let elCount = 0;
    let maxErrors = -opts.count + 1;
    let maxFiltered = -opts.count + 1;
    let done = false;
 
    const fulfilled = value => {
        if (done) {
            return;
        }
 
        if (typeof opts.filter === 'function' && !opts.filter(value)) {
            if (--maxFiltered === 0) {
                done = true;
                reject(new RangeError(`Not enough values pass the \`filter\` option`));
            }
 
            return;
        }
 
        values.push(value);
 
        if (--opts.count === 0) {
            done = true;
            resolve(values);
        }
    };
 
    const rejected = error => {
        if (done) {
            return;
        }
 
        errors.push(error);
 
        if (--maxErrors === 0) {
            done = true;
            reject(new AggregateError(errors));
        }
    };
 
    for (const el of iterable) {
        maxErrors++;
        maxFiltered++;
        elCount++;
        Promise.resolve(el).then(fulfilled, rejected);
    }
 
    if (opts.count > elCount) {
        throw new RangeError(`Expected input to contain at least ${opts.count} items, but contains ${elCount} items`);
    }
});
 
module.exports.AggregateError = AggregateError;