oly-queue

oly queue

import { task, WorkerProvider, Publisher } from "oly-queue";

class App {
  @task add({x, y}) {
    return x + y;
  }
}

const kernel = Kernel.create().with(App, WorkerProvider);
const publisher = kernel.get(Publisher);

await kernel.start();
const job = await publisher.push("App.add", {x: 1, y: 2});
const result = await publisher.wait(job);