| /plugin/authgooglesheets/vendor/guzzlehttp/promises/src/ |
| D | EachPromise.php | 19 private $concurrency; variable in GuzzleHttp\\Promise\\EachPromise
59 $this->concurrency = $config['concurrency'];
125 $this->iterable = $this->concurrency = $this->pending = null;
135 if (!$this->concurrency) {
142 $concurrency = is_callable($this->concurrency)
143 ? call_user_func($this->concurrency, count($this->pending))
144 : $this->concurrency;
145 $concurrency = max($concurrency - count($this->pending), 0);
147 if (!$concurrency) {
156 while (--$concurrency
|
| D | Each.php | 46 * @param int|callable $concurrency
54 $concurrency, argument
61 'concurrency' => $concurrency
71 * @param int|callable $concurrency
78 $concurrency, argument
83 $concurrency,
|
| D | functions.php | 277 * @param int|callable $concurrency
287 $concurrency, argument
291 return Each::ofLimit($iterable, $concurrency, $onFulfilled, $onRejected);
300 * @param int|callable $concurrency
309 $concurrency, argument
312 return Each::ofLimitAll($iterable, $concurrency, $onFulfilled);
|
| /plugin/matrixnotifierwas/vendor/guzzlehttp/promises/src/ |
| D | EachPromise.php | 23 private $concurrency; variable in GuzzleHttp\\Promise\\EachPromise
63 $this->concurrency = $config['concurrency'];
118 $this->iterable = $this->concurrency = $this->pending = null;
128 if (!$this->concurrency) {
137 $concurrency = is_callable($this->concurrency)
138 ? ($this->concurrency)(count($this->pending))
139 : $this->concurrency;
140 $concurrency = max($concurrency - count($this->pending), 0);
142 if (!$concurrency) {
151 while (--$concurrency
|
| D | Each.php | 44 * @param int|callable $concurrency
48 $concurrency, argument
55 'concurrency' => $concurrency,
65 * @param int|callable $concurrency
69 $concurrency, argument
74 $concurrency,
|
| /plugin/authgooglesheets/vendor/google/apiclient-services/src/BigQueryReservation/ |
| D | Reservation.php | 25 public $concurrency; variable in Google\\Service\\BigQueryReservation\\Reservation
54 public function setConcurrency($concurrency) argument
56 $this->concurrency = $concurrency;
63 return $this->concurrency;
|
| /plugin/asciidocjs/node_modules/jake/test/integration/jakelib/ |
| D | concurrent.jake.js | 63 task('simple1', ['A','B'], {concurrency: 2}, function () { property
71 task('simple2', ['C','D'], {concurrency: 2}, function () { property
87 task('concurrentconcurrent', ['simple1','simple2'], {concurrency: 2}, function () { property
95 task('subdep', ['A','Ba'], {concurrency: 2}, function () { property
103 task('fail', ['A', 'B', 'Afail'], {concurrency: 3}, function () { property
|
| /plugin/asciidocjs/node_modules/async/ |
| D | auto.js | 169 function auto(tasks, concurrency, callback) { argument
170 if (typeof concurrency !== 'number') {
172 callback = concurrency;
173 concurrency = null;
180 if (!concurrency) {
181 concurrency = numTasks;
241 while (readyTasks.length && runningTasks < concurrency) {
|
| D | cargoQueue.js | 68 function cargo(worker, concurrency, payload) { argument
69 return (0, _queue2.default)(worker, concurrency, payload);
|
| D | queue.js | 7 exports.default = function (worker, concurrency) { argument
11 }, concurrency, 1);
|
| D | priorityQueue.js | 7 exports.default = function (worker, concurrency) { argument
9 var q = (0, _queue2.default)(worker, concurrency);
|
| D | CHANGELOG.md | 66 - Added `cargoQueue`, a queue with both `concurrency` and `payload` size parameters. (#1567)
185 - You can now limit the concurrency of `auto` tasks. ([#635](https://github.com/caolan/async/issues…
230 - Fix issue with `pause` in `queue` with concurrency enabled ([#946](https://github.com/caolan/asyn…
232 - `auto` will properly handle concurrency when there is no callback ([#966](https://github.com/caol…
240 - `auto` now accepts an optional `concurrency` argument to limit the number o. running tasks ([#637…
295 - `concurrency` can be changed after initialization in `queue` by setting `q.concurrency`. The new …
343 - Throw if queue created with concurrency `0` ([#714](https://github.com/caolan/async/issues/714))
|
| /plugin/asciidocjs/node_modules/async/internal/ |
| D | queue.js | 26 function queue(worker, concurrency, payload) { argument
27 if (concurrency == null) {
28 concurrency = 1;
29 } else if (concurrency === 0) {
127 if (numRunning <= q.concurrency - q.buffer) {
172 concurrency, property
174 buffer: concurrency / 4,
219 while (!q.paused && numRunning < q.concurrency && q._tasks.length) {
237 if (numRunning === q.concurrency) {
|
| /plugin/asciidocjs/node_modules/jake/lib/task/ |
| D | task.js | 66 this.concurrency = 1;
81 if (opts.concurrency) {
82 this.concurrency = opts.concurrency;
147 if (this.concurrency > 1) {
148 async.eachLimit(this.prereqs, this.concurrency,
|
| /plugin/asciidocjs/node_modules/async/dist/ |
| D | async.js | 1024 function auto(tasks, concurrency, callback) { argument
1025 if (typeof concurrency !== 'number') {
1027 callback = concurrency;
1028 concurrency = null;
1035 if (!concurrency) {
1036 concurrency = numTasks;
1099 while(readyTasks.length && runningTasks < concurrency) {
1458 function queue(worker, concurrency, payload) { argument
1459 if (concurrency == null) {
1460 concurrency = 1;
[all …]
|
| D | async.mjs | 391 throw new RangeError('concurrency limit cannot be less than 1')
903 * @param {number} [concurrency=Infinity] - An optional `integer` for
1018 function auto(tasks, concurrency, callback) { argument
1019 if (typeof concurrency !== 'number') {
1020 // concurrency is optional, shift the args.
1021 callback = concurrency;
1022 concurrency = null;
1029 if (!concurrency) {
1030 concurrency = numTasks;
1093 while(readyTasks.length && runningTasks < concurrency) {
[all …]
|
| D | async.min.js | 1 …concurrency-k.buffer&&s("unsaturated"),k.idle()&&s("drain"),k.process()}}function d(e){return!!(0=… property
|
| /plugin/asciidocjs/node_modules/jake/test/integration/ |
| D | jakefile.js | 315 task('selfdeppar', [], {concurrency: 2}, function () { property
333 task("same", same, { concurrency: 2 }, function () { property
349 task("different", different, { concurrency: 2 } , function () { property
|
| /plugin/asciidocjs/node_modules/neo-async/ |
| D | async.js | 7949 function baseQueue(isQueue, worker, concurrency, payload) { argument
7950 if (concurrency === undefined) {
7951 concurrency = 1;
7952 } else if (isNaN(concurrency) || concurrency < 1) {
7962 concurrency: concurrency, property
7966 buffer: concurrency / 4,
8076 if (workers <= q.concurrency - q.buffer) {
8088 while (!q.paused && workers < q.concurrency && q._tasks.length) {
8095 if (workers === q.concurrency) {
8104 while (!q.paused && workers < q.concurrency && q._tasks.length) {
[all …]
|
| D | async.min.js | 29 …concurrency-a.buffer&&a.unsaturated();0===a._tasks.length+h&&a.drain();a.process()}}function l(){f…
30 …concurrency&&n._tasks.length;){for(var a=n._tasks.splice(n.payload||n._tasks.length),b=-1,d=a.leng… property
31 …d=!0},resume:function(){!1!==n.paused&&(n.paused=!1,K(n.concurrency<n._tasks.length?n.concurrency:…
|
| /plugin/elasticsearch/vendor/elasticsearch/elasticsearch/docs/build/Elasticsearch/Namespaces/ |
| D | WatcherNamespace.asciidoc | 124 $params['version'] = (number) Explicit version number for concurrency control
|
| /plugin/webcomponent/_test/data/pages/ |
| D | navbar.txt | 49 [[data:concurrency:|Data Concurrency]]
|
| /plugin/elasticsearch/vendor/elasticsearch/elasticsearch/docs/build/Elasticsearch/ |
| D | Client.asciidoc | 192 $params['version'] = (number) Explicit version number for concurrency control
217 $params['version'] = (number) Explicit version number for concurrency control
301 $params['version'] = (number) Explicit version number for concurrency control
325 $params['version'] = (number) Explicit version number for concurrency control
397 $params['version'] = (number) Explicit version number for concurrency control
461 $params['version'] = (number) Explicit version number for concurrency control
483 $params['version'] = (number) Explicit version number for concurrency control
|
| /plugin/elasticsearch/vendor/elasticsearch/elasticsearch/docs/ |
| D | futures.asciidoc | 10 gain concurrency by providing a batch of requests to process. The batch is
|
| /plugin/diagramsnet/lib/WEB-INF/lib/ |
| D | ehcache-3.8.1.jar | META-INF/
META-INF/MANIFEST.MF
LICENSE
META-INF/maven/
META ... |