@hao-rxtool/queue

!Node.js CI
!NPM version

This library provides a flexible and easy-to-use stream queue implementation for managing asynchronous tasks.

The library is built on top of RxJS, a powerful library for reactive programming.

Installation

Install the library using npm:

``bash
npm install rxjs @hao-rxtool/queue
`

StreamQueue

$3

The StreamQueue class represents a queue that allows enqueueing, dequeuing, and notifying subscribers of its status changes.

It provides a set of observables and methods for interacting with the queue.

$3

`typescript
import { StreamQueue, StreamQueueStatus } from '@hao-rxtool/queue';

// Create a new stream queue
const queue = new StreamQueue();

// Listen for the status of the queue changes
queue.statusChange.subscribe((status) => {
console.log(Queue status: ${status}); // StreamQueueStatus
});

// Listen for an item is ready to be dequeued
queue.whenReadyToDequeue.subscribe((item) => {
console.log(When ready to dequeue item: ${item});
});

// Listen for an item has been dequeued
queue.whenDequeued.subscribe((item) => {
console.log(Dequeued item: ${item});
});

// Enqueue an item
queue.enqueue(1);

// Dequeue an item
queue.dequeue();

// Enqueues an item and waits for it to be dequeued
queue.enqueueAndWaitDequeue(2).subscribe((item) => {
console.log(Enqueue and wait dequeue item: ${item});
});

queue.dequeue();

// Destroy the queue when no longer needed
queue.destroy();
`

StreamQueueManager

$3

The StreamQueueManager class acts as a manager for multiple StreamQueue instances, allowing you to organize and control queues efficiently.

$3

`typescript
import { StreamQueueManager, StreamQueueManagerOption } from '@hao-rxtool/queue';

// Create a queue manager with optional options
const options: StreamQueueManagerOption = { poolSize: 5 };
const manager = new StreamQueueManager(options);


const queueName = 'exampleQueue';
// Listen for status changes of a specific queue
manager.statusChange(queueName).subscribe((status) => {
console.log(Queue status: ${status});
});

// Listen for an item is ready to be dequeued of a specific queue
manager.whenReadyToDequeue(queueName).subscribe((item) => {
console.log(When ready to dequeue item: ${item});
});

// Listen for an item has been dequeued of a specific queue
manager.whenDequeued(queueName).subscribe((item) => {
console.log(Dequeued item: ${item});
});

// Enqueue an item to the specific queue
manager.enqueue(queueName, 1);

// Dequeue an item from a queue
manager.dequeue(queueName);

// Enqueues an item to the specific queue and waits for it to be dequeued
manager.enqueueAndWaitDequeue(queueName, 2).subscribe((item) => {
console.log(Enqueue and wait dequeue item: ${item});
});

// Clear all queues from the manager
manager.clear();
``

License

This library is licensed under the MIT License - see the LICENSE file for details.