buzy
Promise based async queue manager for node and browser.
Buzy is a blackbox into which you push promises and at each point in time you can know if any of the promises are still in pending state(busy state). Optionally you can subscribe for the event bus which will let you know when there is change in the blackbox state
Its particularly useful where you want to know if your system is busy with async activities like ajax calls etc. You can push promises in to the queue and buzy will do the job of letting you know when the state of the system changes. Use cases can be:
- Show loaders on ajax calls
- Check if any of your tasks are pending before closing the browser and similar others
Installation
$ npm install buzySyntax
new Buzy(subscribers, buzies);- subscribers - array of functions which will be called upon the change when there is a state change or when a promise is resolved/reject(this wont be triggered for buzies dependent on other buzies)
- buzies - array of buzies to subscribe on to
Subscribers will be called with the following message data structure
{
code: number, // 0 - STATE change, 1 - RESOLVE, 2 - REJECT
busy: true/false,
promise: promise, //promise which is last resolved/rejected
value: value, // value of the resolution
error: error // error of the rejection
}New promises can be added with:
buzy.addPromise(promise) //single promise
buzy.addPromises(promises) //array of promisesNew subscribers can be added with:
buzy.addSubscriber(subscriber) //single subscriber
buzy.addSubscribers(subscribers) //array of subscribersNew buzies can be added with:
buzy.addBuzy(buzy) //single buzy
buzy.addBuzies(buzies)//array of buziesTo check if buzy is busy or not:
buzy.isBusy() //true or falseExamples
import Buzy from 'buzy';
const buzy1 = new Buzy([function(message) {
console.log(message);
/*
Prints the following:
{
code: 0,
busy: true
}
And after 1000 milliseconds
{
code: 1,
promise: Promise{'done'},
value: 'done'
}
And then
{
code: 0,
busy: false
}
*/
}]);
const buzy2 = new Buzy([function(message) {
console.log(message);
/*
Prints the following:
{
code: 0,
busy: true
}
And after fetch is complete
{
code: 1 or 2 based on fetch result,
promise: Promise{res from fetch},
value: value or error: error based fetch result
}
And then after buzy1 is done with all the tasks
{
code: 0,
busy: false
}
*/
}], [buzy1]);
buzy1.addPromise(new Promise(function(resolve, reject) {
setTimeout(function() {
resolve('done');
}, 1000);
}))
buzy2.addPromise(fetch('http://someurl'));Check Buzy.test.js for more exmaples
To do
- Cancellation of requests
- Removal of subscribers/buzies
- You tell me!