oly-queue
v1.0.0
Published
oly-queue
Readme
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);