Offload functions to worker threads with shared memory primitives for Node.js.
1import { mo } from 'moroutine';
2
3export const makeMultiplier = mo(import.meta, (factor: number): number => {
4 return factor;
5});
6
7export const streamMultiplied = mo(import.meta, async function* (factor: number, count: number) {
8 for (let i = 0; i < count; i++) {
9 yield i * factor;
10 }
11});