(spinner, workQueue, installed, waitQueue)
| 103014 | } |
| 103015 | |
| 103016 | worker(spinner, workQueue, installed, waitQueue) { |
| 103017 | var _this5 = this; |
| 103018 | |
| 103019 | return (0, (_asyncToGenerator2 || _load_asyncToGenerator()).default)(function* () { |
| 103020 | while (workQueue.size > 0) { |
| 103021 | // find a installable package |
| 103022 | const pkg = _this5.findInstallablePackage(workQueue, installed); |
| 103023 | |
| 103024 | // can't find a package to install, register into waitQueue |
| 103025 | if (pkg == null) { |
| 103026 | spinner.clear(); |
| 103027 | yield new Promise(function (resolve) { |
| 103028 | return waitQueue.add(resolve); |
| 103029 | }); |
| 103030 | continue; |
| 103031 | } |
| 103032 | |
| 103033 | // found a package to install |
| 103034 | workQueue.delete(pkg); |
| 103035 | if (_this5.packageCanBeInstalled(pkg)) { |
| 103036 | yield _this5.runCommand(spinner, pkg); |
| 103037 | } |
| 103038 | installed.add(pkg); |
| 103039 | for (var _iterator8 = waitQueue, _isArray8 = Array.isArray(_iterator8), _i8 = 0, _iterator8 = _isArray8 ? _iterator8 : _iterator8[Symbol.iterator]();;) { |
| 103040 | var _ref13; |
| 103041 | |
| 103042 | if (_isArray8) { |
| 103043 | if (_i8 >= _iterator8.length) break; |
| 103044 | _ref13 = _iterator8[_i8++]; |
| 103045 | } else { |
| 103046 | _i8 = _iterator8.next(); |
| 103047 | if (_i8.done) break; |
| 103048 | _ref13 = _i8.value; |
| 103049 | } |
| 103050 | |
| 103051 | const workerResolve = _ref13; |
| 103052 | |
| 103053 | workerResolve(); |
| 103054 | } |
| 103055 | waitQueue.clear(); |
| 103056 | } |
| 103057 | })(); |
| 103058 | } |
| 103059 | |
| 103060 | init(seedPatterns) { |
| 103061 | var _this6 = this; |
no test coverage detected