Skip to content

A dispatch queue built in Typescript with the ability to configure multiple queue processors.

License

Notifications You must be signed in to change notification settings

myty/dispatch-queue

Repository files navigation

DispatchQueue

GitHub version deno land npm version Coverage Status

A dispatch queue with the ability to configure multiple queue processors.

Installation

Node.js

# npm
npm install --save @myty/dispatch-queue
# yarn
yarn add @myty/dispatch-queue
# pnpm
pnpm install --save @myty/dispatch-queue

Deno

import DispatchQueue from "https://deno.land/x/dispatch_queue/mod.ts";

Example Usage

const dispatcher = new DispatchQueue<string>({
  processor: (stringValue, workerId) => {
    conosle.log(`Worker, '${workerId}', is processing: '${stringValue}'`);
  },
});

dispatcher.process("test1");
// OUTPUT: "Worker, 'worker-1', is processing: 'test1'"

About

A dispatch queue built in Typescript with the ability to configure multiple queue processors.

Topics

Resources

License

Stars

Watchers

Forks