Monday, May 20, 2024
 Popular · Latest · Hot · Upcoming
59
rated 0 times [  63] [ 4]  / answers: 1 / hits: 23343  / 10 Years ago, sat, february 15, 2014, 12:00:00

I use mbostock/queue for queuing few async operation. It is more to rate limit (UI generate few events, where the backend can process it slowly), and also to make sure they are processed sequentially. I use it like



function request(d, cb) {
//some async oper
add.then(function(){
cb(null, finished )
})
}

var addQ = queue(1);
addQ.defer(request) //called by few req at higher rates generated by UI


I already uses angular.js $q for async operation. So, do I have to use mbostock/queue, or can I build a queue out of $q (which is in spirit https://github.com/kriskowal/q)



Thanks.


More From » angularjs

 Answers
4

Basic $q Chain Example



Yes you can build a chained queue using Angular's $q! Here is an example that shows you how you could use recursion to create a queue of any length. Each post happens in succession (one after another). The second post will not start until the first post has finished.



This can be helpful when writing to databases. If the database does not have it's own queue on the backend, and you make multiple writes at the same time, you may find that not all of your data is saved!



I have added a Plunkr example to demonstrate this code in action.



$scope.setData = function (data) {

// This array will hold the n-length queue
var promiseStack = [];

// Create a new promise (don't fire it yet)
function newPromise (key, data) {
return function () {
var deferred = $q.defer();

var postData = {};
postData[key] = data;

// Post the the data ($http returns a promise)
$http.post($scope.postPath, postData)
.then(function (response) {

// When the $http promise resolves, we also
// resolve the queued promise that contains it
deferred.resolve(response);

}, function (reason) {
deferred.reject(reason);
});

return deferred.promise;
};
}

// Loop through data creating our queue of promises
for (var key in data) {
promiseStack.push(newPromise(key, data[key]));
}

// Fire the first promise in the queue
var fire = function () {

// If the queue has remaining items...
return promiseStack.length &&

// Remove the first promise from the array
// and execute it
promiseStack.shift()()

// When that promise resolves, fire the next
// promise in our queue
.then(function () {
return fire();
});
};

// Begin the queue
return fire();
};


You can use a simple function to begin your queue. For the sake of this demonstration, I am passing an object full of keys to a function that will split these keys into individual posts, then POST them to Henry's HTTP Post Dumping Server. (Thanks Henry!)



$scope.beginQueue = function () {

$scope.setData({
a: 0,
b: 1,
/* ... all the other letters of the alphabet ... */
y: 24,
z: 25

}).then(function () {

console.log('Everything was saved!');

}).catch(function (reason) {
console.warn(reason);
});
};


Here is a link to the Plunkr example if you would like to try out this code.


[#72510] Thursday, February 13, 2014, 11 Years  [reply] [flag answer]
Only authorized users can answer the question. Please sign in first, or register a free account.
andreguym

Total Points: 125
Total Questions: 112
Total Answers: 103

Location: Wallis and Futuna
Member since Tue, Mar 30, 2021
3 Years ago
;