Caplink

A modernized fork of Comlink with many open PRs merged and the ability to use proxies as values in Caplink calls.

// file: w1.ts
import * as Caplink from '@workers/caplink';
export class Greeter {
  helloWorld(name = "World") { 
    console.log(`Hello, ${name}!`);
  }
}
export class W1Fns {
  static newGreeter() {
    return Caplink.proxy(new Greeter());
  }
}
Caplink.expose(W1Fns);

// file: w2.ts
import * as Caplink from '@workers/caplink';
import type { Greeter } from "./w1.ts";

export class W2Fns {
  static async greet(greeter: Caplink.Remote<Greeter>) {
    using greeter_ = greeter; // can opt into explicit resource management
    await greeter_.helloWorld("Worker 2");
  } // local resources freed
}
Caplink.expose(W2Fns);

// file: index.ts
import * as Caplink from '@workers/caplink';
import type { W1Fns } from "./w1.ts";
import type { W2Fns } from "./w2.ts";

const w1 = Caplink.wrap<typeof W1Fns>(
  new Worker(new URL("./w1.ts", import.meta.url), { type: "module" }),
);
const w2 = Caplink.wrap<typeof W2Fns>(
  new Worker(new URL("./w2.ts", import.meta.url), { type: "module" }),
);

using remoteGreeter = await w1.newGreeter();
await remoteGreeter.helloWorld(); // logs "Hello, World" in w1.ts
await w2.greet(remoteGreeter);    // logs "Hello, Worker 2" in w1.ts