| /third_party/node/deps/npm/node_modules/p-map/ |
| D | index.js | 8 concurrency = Infinity, argument
17 if (!((Number.isSafeInteger(concurrency) || concurrency === Infinity) && concurrency >= 1)) {
18 …` to be an integer from 1 and up or \`Infinity\`, got \`${concurrency}\` (${typeof concurrency})`);
73 for (let i = 0; i < concurrency; i++) {
|
| /third_party/node/test/parallel/ |
| D | test-runner-option-validation.js | 17 [Symbol(), {}, [], () => {}, 1n, '1'].forEach((concurrency) => {
18 assert.throws(() => test({ concurrency }), { code: 'ERR_INVALID_ARG_TYPE' }); field
20 [-1, 0, 1.1, -Infinity, NaN, 2 ** 33, Number.MAX_SAFE_INTEGER].forEach((concurrency) => {
21 assert.throws(() => test({ concurrency }), { code: 'ERR_OUT_OF_RANGE' }); field
23 [null, undefined, 1, 2 ** 31, true, false].forEach((concurrency) => {
25 test({ concurrency }); field
|
| D | test-stream-map.js | 165 }, 2), { signal: ac.signal, concurrency: 2, highWaterMark: 0 }); property
185 }, { concurrency: 2 }); property
210 }, { concurrency: 2 }); property
257 }, { concurrency: 6 }); property
305 }, { concurrency: 5, highWaterMark: 7 }); property
329 }, { concurrency: 2 }) property
348 concurrency: 'Foo' property
351 concurrency: -1 property
|
| D | test-runner-inspect.mjs | 33 …inspector with --test forces running at a concurrency of 1\. Use the inspectPort option to run wit…
42 …inspector with --test forces running at a concurrency of 1\. Use the inspectPort option to run wit…
56 …inspector with --test forces running at a concurrency of 1\. Use the inspectPort option to run wit…
|
| D | test-runner-cli-concurrency.js | 13 assert.match(cp.stderr.toString(), /concurrency: true,/);
19 assert.match(cp.stderr.toString(), /concurrency: 1,/);
25 assert.match(cp.stderr.toString(), /concurrency: 2,/);
|
| D | test-runner-concurrency.js | 14 describe('Concurrency option (boolean) = true', { concurrency: true }, () => { property
27 { concurrency: false }, property
41 describe('concurrency: true implies Infinity', { concurrency: true }, () => { property
|
| D | test-stream-filter.js | 124 }, { signal: ac.signal, concurrency: 2 }); property
146 }, { concurrency: 2 }); property
160 concurrency: 'Foo' property
|
| D | test-stream-some-find-every.mjs | 114 }, { concurrency: 2 }); property
150 concurrency: 'Foo'
152 }, /ERR_OUT_OF_RANGE/, `${op} should throw for invalid concurrency`).then(common.mustCall());
155 … }, /ERR_INVALID_ARG_TYPE/, `${op} should throw for invalid concurrency`).then(common.mustCall());
|
| D | test-stream-flatMap.js | 78 }), { signal: ac.signal, concurrency: 2 }); property
114 concurrency: 'Foo' property
|
| D | test-stream-forEach.js | 99 }, { signal: ac.signal, concurrency: 2, highWaterMark: 0 }); property
120 concurrency: 'Foo' property
|
| /third_party/node/benchmark/test_runner/ |
| D | suite-tests.js | 13 concurrency: ['yes', 'no'], property
19 async function run({ numberOfSuites, testsPerSuite, testType, concurrency }) { field
20 concurrency = concurrency === 'yes';
28 describe(`${i}`, { concurrency }, () => { field
42 describe(`${i}`, { concurrency }, () => { field
|
| /third_party/node/benchmark/tls/ |
| D | tls-connect.js | 7 concurrency: [1, 10], property
14 let concurrency; variable
19 concurrency = conf.concurrency;
35 for (let i = 0; i < concurrency; i++)
|
| /third_party/node/lib/internal/streams/ |
| D | operators.js | 81 let concurrency = 1;
82 if (options?.concurrency != null) {
83 concurrency = MathFloor(options.concurrency);
86 let highWaterMark = concurrency - 1;
91 validateInteger(concurrency, 'options.concurrency', 1);
94 highWaterMark += concurrency;
121 cnt < concurrency &&
162 if (!done && (queue.length >= highWaterMark || cnt >= concurrency)) {
|
| /third_party/node/lib/internal/test_runner/ |
| D | test.js | 212 const { concurrency, loc, only, timeout, todo, signal } = options;
227 this.concurrency = 1;
246 this.concurrency = parent.concurrency;
263 switch (typeof concurrency) {
265 validateUint32(concurrency, 'options.concurrency', 1);
266 this.concurrency = concurrency;
270 if (concurrency) {
271 this.concurrency = parent === null ?
274 this.concurrency = 1;
279 if (concurrency != null)
[all …]
|
| /third_party/node/test/pummel/ |
| D | test-net-many-clients.js | 29 const concurrency = 50; constant
90 for (let i = 0; i < concurrency; i++) {
92 if (++finished_clients === concurrency) server.close();
98 assert.strictEqual(total_connections, connections_per_client * concurrency);
|
| /third_party/node/lib/internal/main/ |
| D | test_runner.js | 27 let concurrency = getOptionValue('--test-concurrency') || true; variable
33 concurrency = 1;
63 concurrency, property
|
| /third_party/node/deps/npm/node_modules/cacache/lib/ |
| D | verify.js | 23 concurrency: 20, property
151 { concurrency: opts.concurrency } property
211 { concurrency: opts.concurrency } property
|
| /third_party/node/test/es-module/ |
| D | test-esm-extensionless-esm-and-wasm.mjs | 7 describe('extensionless ES modules within a "type": "module" package scope', { concurrency: true },… property
32 describe('extensionless Wasm modules within a "type": "module" package scope', { concurrency: true … property
58 describe('extensionless ES modules within no package scope', { concurrency: true }, () => { property
82 describe('extensionless Wasm within no package scope', { concurrency: true }, () => { property
|
| D | test-esm-type-flag-cli-entry.mjs | 6 describe('--experimental-default-type=module should not support extension searching', { concurrency… property
36 describe('--experimental-default-type=module should not parse paths as URLs', { concurrency: true }… property
|
| /third_party/node/test/fixtures/test-runner/concurrency/ |
| D | b.mjs | 7 const file = await fs.readFile(path.resolve(tmpdir.path, 'test-runner-concurrency'), 'utf8');
9 await fs.writeFile(path.resolve(tmpdir.path, 'test-runner-concurrency'), 'b.mjs');
|
| D | a.mjs | 6 await fs.writeFile(path.resolve(tmpdir.path, 'test-runner-concurrency'), 'a.mjs');
8 const file = await fs.readFile(path.resolve(tmpdir.path, 'test-runner-concurrency'), 'utf8');
|
| /third_party/libuv/test/ |
| D | benchmark-pound.c | 271 static int pound_it(int concurrency, in pound_it() argument
290 do_setup(concurrency, arg); in pound_it()
292 r = do_connect(concurrency, make_connect, arg); in pound_it()
304 concurrency, in pound_it()
|
| /third_party/typescript/tests/cases/docker/pyright/ |
| D | Dockerfile | 7 RUN npx lerna exec --stream --concurrency 1 -- npm install /typescript.tgz --exact --ignore-scripts…
9 CMD [ "lerna", "exec", "--stream", "--concurrency", "1", "--no-bail", "--", "tsc", "--noEmit" ]
|
| /third_party/node/test/fixtures/test-runner/ |
| D | reporters.js | 4 test('nested', { concurrency: 4 }, async (t) => { property
|
| /third_party/node/test/fixtures/test-runner/output/ |
| D | output.js | 111 test('level 0a', { concurrency: 4 }, async (t) => { property
159 test('top level', { concurrency: 2 }, async (t) => { property
|