MCPcopy Index your code
hub / github.com/vercel/hyper / worker

Method worker

bin/yarn-standalone.js:103016–103058  ·  view source on GitHub ↗
(spinner, workQueue, installed, waitQueue)

Source from the content-addressed store, hash-verified

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;

Callers 1

initMethod · 0.80

Calls 7

_load_asyncToGeneratorFunction · 0.85
packageCanBeInstalledMethod · 0.80
runCommandMethod · 0.80
clearMethod · 0.45
addMethod · 0.45
nextMethod · 0.45

Tested by

no test coverage detected