Comparing version 0.6.2 to 0.7.0
@@ -724,2 +724,5 @@ /*jshint onevar: false, indent:4 */ | ||
function _insert(q, data, pos, callback) { | ||
if (!q.started){ | ||
q.started = true; | ||
} | ||
if (!_isArray(data)) { | ||
@@ -762,2 +765,3 @@ data = [data]; | ||
drain: null, | ||
started: false, | ||
paused: false, | ||
@@ -767,2 +771,6 @@ push: function (data, callback) { | ||
}, | ||
kill: function () { | ||
q.drain = null; | ||
q.tasks = []; | ||
}, | ||
unshift: function (data, callback) { | ||
@@ -769,0 +777,0 @@ _insert(q, data, true, callback); |
@@ -6,3 +6,3 @@ { | ||
"author": "Caolan McMahon", | ||
"version": "0.6.2", | ||
"version": "0.7.0", | ||
"repository" : { | ||
@@ -9,0 +9,0 @@ "type" : "git", |
@@ -921,3 +921,3 @@ # Async.js | ||
function(arg1, arg2, callback){ | ||
// arg1 now equals 'one' and arg2 now equals 'two' | ||
// arg1 now equals 'one' and arg2 now equals 'two' | ||
callback(null, 'three'); | ||
@@ -1004,3 +1004,3 @@ }, | ||
var User = request.models.User; | ||
asyc.seq( | ||
async.seq( | ||
_.bind(User.get, User), // 'User.get' has signature (id, callback(err, data)) | ||
@@ -1081,2 +1081,3 @@ handleError, | ||
* `length()` - a function returning the number of items waiting to be processed. | ||
* `started` - a function returning whether or not any items have been pushed and processed by the queue | ||
* `running()` - a function returning the number of items currently being processed. | ||
@@ -1098,2 +1099,3 @@ * `idle()` - a function returning false if there are items waiting or being processed, or true if not. | ||
* `resume()` - a function that resumes the processing of queued tasks when the queue is paused. | ||
* `kill()` - a function that empties remaining tasks from the queue forcing it to go idle. | ||
@@ -1348,2 +1350,3 @@ __Example__ | ||
* `times` - An integer indicating how many times to attempt the `task` before giving up. Defaults to 5. | ||
* `task(callback, results)` - A function which receives two arguments: (1) a `callback(err, result)` | ||
@@ -1350,0 +1353,0 @@ which must be called when finished, passing `err` (which can be `null`) and the `result` of |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
85909
979
1636