1234567891011121314151617181920212223242526272829 |
- var abort = require('./abort.js')
- , async = require('./async.js')
- ;
- // API
- module.exports = terminator;
- /**
- * Terminates jobs in the attached state context
- *
- * @this AsyncKitState#
- * @param {function} callback - final callback to invoke after termination
- */
- function terminator(callback)
- {
- if (!Object.keys(this.jobs).length)
- {
- return;
- }
- // fast forward iteration index
- this.index = this.size;
- // abort jobs
- abort(this);
- // send back results we have so far
- async(callback)(null, this.results);
- }
|