Skip to content

Commit 20092c3

Browse files
committed
better solution for jaredwray#21. Thanks @aletorrado
1 parent d497205 commit 20092c3

File tree

2 files changed

+12
-12
lines changed

2 files changed

+12
-12
lines changed

lib/caching.js

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -50,13 +50,13 @@ var caching = function(args) {
5050
self.queues[key] = [{cb: cb, domain: process.domain}];
5151

5252
function fillCallbacks(err, data) {
53-
self.queues[key].forEach(function(task) {
54-
process.nextTick(function() {
55-
var taskDomain = task.domain || domain.create();
56-
taskDomain.bind(task.cb)(err, data);
57-
});
58-
});
53+
var waiting = self.queues[key];
5954
delete self.queues[key];
55+
56+
waiting.forEach(function(task) {
57+
var taskDomain = task.domain || domain.create();
58+
taskDomain.bind(task.cb)(err, data);
59+
});
6060
}
6161

6262
self.store.get(key, function(err, result) {

lib/multi_caching.js

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -78,13 +78,13 @@ var multi_caching = function(caches) {
7878
self.queues[key] = [{cb: cb, domain: process.domain}];
7979

8080
function fillCallbacks(err, data) {
81-
self.queues[key].forEach(function(task) {
82-
process.nextTick(function() {
83-
var taskDomain = task.domain || domain.create();
84-
taskDomain.bind(task.cb)(err, data);
85-
});
86-
});
81+
var waiting = self.queues[key];
8782
delete self.queues[key];
83+
84+
waiting.forEach(function(task) {
85+
var taskDomain = task.domain || domain.create();
86+
taskDomain.bind(task.cb)(err, data);
87+
});
8888
}
8989

9090
get_from_highest_priority_cache(key, function(err, result, index) {

0 commit comments

Comments
 (0)