Skip to content

Commit

Permalink
cosmetic
Browse files Browse the repository at this point in the history
  • Loading branch information
yosefd committed Aug 14, 2013
1 parent 648ece9 commit 842622f
Showing 1 changed file with 2 additions and 4 deletions.
6 changes: 2 additions & 4 deletions lib/rebus.js
Original file line number Diff line number Diff line change
Expand Up @@ -162,7 +162,7 @@ module.exports = function (folder, options, callback) {
// No need to publish is the data is the same.
return callback();
}
// The 1st notification if for subscription.
// The 1st notification if for the subscription.
// The 2nd notification is for the change.
var count = 2;
var handler = subscribe(prop, function(obj) {
Expand All @@ -189,9 +189,7 @@ module.exports = function (folder, options, callback) {
}
// Publishing of the same object should be queued and executed one after
// completion of another.
publishQueues[prop].push(obj, function(err) {
return callback(err);
});
publishQueues[prop].push(obj, callback);
}

// Subscribe on changes.
Expand Down

0 comments on commit 842622f

Please sign in to comment.