fiber/par_map

Map over a collection with bounded concurrency

// 1. make an app
const app = mvfm(prelude, fiber);

// 2. make a program
const prog = app({ nums: array("number") }, ($) => {
  return $.par($.input.nums, { concurrency: 2 }, (n) =>
    $.mul(n, 10)
  );
});

// 3. run
await fold(
  defaults(app),
  injectInput(prog, { nums: [1, 2, 3, 4] })
);

// 1. make an app
const app = mvfm(prelude, fiber);

// 2. make a program
const prog = app({ nums: array("number") }, ($) => {
  return $.par($.input.nums, { concurrency: 2 }, (n) =>
    $.mul(n, 10)
  );
});

// 3. run
await fold(
  defaults(app),
  injectInput(prog, { nums: [1, 2, 3, 4] })
);

// 1. make an app
const app = mvfm(prelude, fiber);

// 2. make a program
const prog = app({ nums: array("number") }, ($) => {
  return $.par($.input.nums, { concurrency: 2 }, (n) =>
    $.mul(n, 10)
  );
});

// 3. run
await fold(
  defaults(app),
  injectInput(prog, { nums: [1, 2, 3, 4] })
);

Ctrl+Enter