Oly-queue NPM | npm.io

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);

oly typescript bull

@types/bull bull

@everything-registry/sub-chunk-2374 @zalastax/nolb-ol

7 years ago

8 years ago

8 years ago

8 years ago