genMerge1 = promises =>
Generators.queue(change => promises.forEach(p => p.then(change)))
genMerge2 = async function*(promises) {
let nb = promises.length
for await (const res of genMerge1(promises)) {
yield res
if (!--nb) break
}
}
genMerge3 = async function*(promises) {
const map = new Map(promises.map((p, i) => [i, p.then(res => [i, res])]));
while (map.size) {
const [key, result] = await Promise.race(map.values());
yield result;
map.delete(key);
}
}
promises = () =>
[...Array(100)].map((_, i) => Promises.delay(Math.random() * 10000, i))
genMerge1(promises())
genMerge2(promises())
genMerge3(promises())
Purpose-built for displays of data
Observable is your go-to platform for exploring data and creating expressive data visualizations. Use reactive JavaScript notebooks for prototyping and a collaborative canvas for visual data exploration and dashboard creation.
