Comparing version 0.9.34 to 0.9.50
@@ -186,3 +186,3 @@ var async = require('async'); | ||
barrel.close = function( ){ | ||
barrel.close = function( callback ){ | ||
var self = this; | ||
@@ -194,9 +194,12 @@ | ||
var series = []; | ||
self.firestarters.forEach( function( fs ){ | ||
if( fs.close ){ | ||
fs.close(); | ||
} | ||
series.push( function(cb){ | ||
if( fs.close ) fs.close( cb ); | ||
else cb(); | ||
} ); | ||
} ); | ||
async.series( series, callback ); | ||
}; | ||
module.exports = Barrel; |
@@ -234,5 +234,6 @@ var Communication = require('./Communication'); | ||
firestarter.close = function( ){ | ||
firestarter.close = function( callback ){ | ||
callback(); | ||
}; | ||
module.exports = Firestarter; |
@@ -90,7 +90,8 @@ var Firestarter = require('./Firestarter'); | ||
firestorm.close = function( ){ | ||
firestorm.close = function( callback ){ | ||
if( this.object.close ) | ||
this.object.close(); | ||
this.object.close( callback ); | ||
else callback(); | ||
}; | ||
module.exports = Firestormstarter; |
@@ -8,3 +8,3 @@ var Communication = require('../lib/Communication'); | ||
var VERSION = exports.VERSION = '0.9.34'; | ||
var VERSION = exports.VERSION = '0.9.50'; | ||
@@ -197,7 +197,8 @@ function extend(obj, extension){ | ||
* @method close | ||
* @param {Function} callback Mandatory callback function called when all elements has been notified to close | ||
*/ | ||
inflicter.close = function( ){ | ||
this.barrel.close(); | ||
inflicter.close = function( callback ){ | ||
this.barrel.close( callback ); | ||
}; | ||
module.exports = Inflicter; |
{ | ||
"name": "harcon", | ||
"version": "0.9.34", | ||
"version": "0.9.50", | ||
"description": "Messaging/Service Bus for the harmonic convergence of node-based enterprise entities.", | ||
@@ -49,3 +49,3 @@ "keywords": [ | ||
}, | ||
"_id": "harcon@0.9.34" | ||
"_id": "harcon@0.9.50" | ||
} |
@@ -214,3 +214,3 @@ Harcon - Messaging/Service Bus for the harmonic convergence of node-based enterprise entities or in-browser communication between web components | ||
}; | ||
... | ||
``` | ||
@@ -229,3 +229,3 @@ That ignite can be used to chain messages, which means to send messages during the processing of a received one. The tool to initiate sub-workflows. | ||
}; | ||
... | ||
``` | ||
@@ -232,0 +232,0 @@ That ignite function is injected by the [harcon](https://github.com/imrefazekas/harcon) when you publish the components. |
@@ -114,5 +114,5 @@ var chai = require("chai"); | ||
// Shuts down Harcon when it is not needed anymore | ||
inflicter.close(); | ||
done(); | ||
inflicter.close( function(){ done(); } ); | ||
//done(); | ||
}); | ||
}); |
Sorry, the diff of this file is not supported yet
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
965085
16642