Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
if (!i.value) continue;
if (i === main) {
yield i.value;
} else {
if (i.value.type === "FLUSH") {
if (i.value.awaiting) {
i.value.awaiting.delete(i.key);
if (i.value.awaiting.size) continue;
}
yield { type: "FLUSH" };
} else yield { type: "ITEM", value: i.value, key: i.key };
}
}
} finally {
for (const i of threads.values()) i.source.stop();
await R.all([...threads.values()].map(i => i.iter.return()));
}
};
}