/*
* Async Manager
* auteur : jser.me
*
* Utilisation :
* var asyncMg = require('./AsyncManager') ;
* asyncMg
* .push(function(next){
* some_aysnc_method().on('success'{
* next();
* suivant( );
* })
* })
* .push( ... )
* .run() //Exécuter
* .on('succès', function() {
* allThings_is_down();
* });
function typeOf( obj ){
return Object.prototype.toString.call( obj ).match(/[object ([^]]*)]/)[1];
}
fonction AsyncManager( arg ){
this.execArrys = [];
this.push( arg );
}
//Utilisez la méthode d'héritage fournie par le système
require('util').inherits( AsyncManager, require('events').EventEmitter );
//Marquer le nombre de fonctions exécutées avec succès
AsyncManager.prototype.succCount = 0;
//Ajouter
AsyncManager.prototype.push = function( arg ) {
var This = this;
if( typeOf(arg) == 'Array' ){
arg.forEach( function(v,i){
This.execArrys.push( v );
});
.
//Exécuter
AsyncManager.prototype.run = function(){
var self = this;
If( this.succCount == this.execArrys.length ) {
//Les événements sont déclenchés une fois que toutes les fonctions ont été exécutées avec succès
this.emit( 'success' );
} else {
this.execArrys[ this.succCount ]( self.run.bind( self ) );
}
this.succCount ;
return this; //Chaîne un
};
exports = module.exports = function( arg ){
return new AsyncManager( arg );
}