+4

package.json

reviewed

··· 3 3 "version": "0.0.0", 4 4 "type": "module", 5 5 "exports": "./src/index.ts", 6 6 + "engines": { 7 7 + "node": ">=22" 8 8 + }, 9 9 + "packageManager": "pnpm@10.33.0", 6 10 "scripts": { 7 11 "test": "node --experimental-strip-types --test test/**/*.test.ts" 8 12 }

+9

pnpm-lock.yaml

reviewed

··· 1 1 + lockfileVersion: '9.0' 2 2 + 3 3 + settings: 4 4 + autoInstallPeers: true 5 5 + excludeLinksFromLockfile: false 6 6 + 7 7 + importers: 8 8 + 9 9 + .: {}

+2

src/index.ts

reviewed

··· 1 1 + export { mo } from './mo.ts'; 2 2 + export { Task } from './task.ts';

+18

src/mo.ts

reviewed

··· 1 1 + import { registry } from './registry.ts'; 2 2 + import { Task } from './task.ts'; 3 3 + 4 4 + const counters = new Map<string, number>(); 5 5 + 6 6 + export function mo<A extends unknown[], R>( 7 7 + importMeta: ImportMeta, 8 8 + fn: (...args: A) => R, 9 9 + ): (...args: A) => Task<R> { 10 10 + const url = importMeta.url; 11 11 + const index = counters.get(url) ?? 0; 12 12 + counters.set(url, index + 1); 13 13 + const id = `${url}#${index}`; 14 14 + 15 15 + registry.set(id, fn); 16 16 + 17 17 + return (...args: A) => new Task<R>(id, args); 18 18 + }

+1

src/registry.ts

reviewed

··· 1 1 + export const registry = new Map<string, (...args: any[]) => any>();

+16

src/task.ts

reviewed

··· 1 1 + export class Task<T> { 2 2 + readonly id: string; 3 3 + readonly args: unknown[]; 4 4 + 5 5 + constructor(id: string, args: unknown[]) { 6 6 + this.id = id; 7 7 + this.args = args; 8 8 + } 9 9 + 10 10 + then<T1 = T, T2 = never>( 11 11 + onfulfilled?: ((value: T) => T1 | PromiseLike<T1>) | null, 12 12 + onrejected?: ((reason: any) => T2 | PromiseLike<T2>) | null, 13 13 + ): Promise<T1 | T2> { 14 14 + throw new Error('Not implemented: wire up dedicated runner'); 15 15 + } 16 16 + }

+33

test/mo.test.ts

reviewed

··· 1 1 + import { describe, it } from 'node:test'; 2 2 + import assert from 'node:assert/strict'; 3 3 + import { mo } from 'moroutine'; 4 4 + 5 5 + describe('mo()', () => { 6 6 + it('returns a function', () => { 7 7 + const double = mo(import.meta, (x: number) => 2 * x); 8 8 + assert.equal(typeof double, 'function'); 9 9 + }); 10 10 + 11 11 + it('calling it returns a Task with correct args', () => { 12 12 + const double = mo(import.meta, (x: number) => 2 * x); 13 13 + const task = double(2); 14 14 + assert.deepEqual(task.args, [2]); 15 15 + }); 16 16 + 17 17 + it('Task is a thenable', () => { 18 18 + const double = mo(import.meta, (x: number) => 2 * x); 19 19 + const task = double(2); 20 20 + assert.equal(typeof task.then, 'function'); 21 21 + }); 22 22 + 23 23 + it('tasks from the same moroutine share an id', () => { 24 24 + const double = mo(import.meta, (x: number) => 2 * x); 25 25 + assert.equal(double(1).id, double(2).id); 26 26 + }); 27 27 + 28 28 + it('different moroutines have different ids', () => { 29 29 + const a = mo(import.meta, (x: number) => x + 1); 30 30 + const b = mo(import.meta, (x: number) => x + 2); 31 31 + assert.notEqual(a(1).id, b(1).id); 32 32 + }); 33 33 + });