BreizhHardware/memoizee
1
0
Fork 0
mirror of https://github.com/BreizhHardware/memoizee.git synced 2026-01-18 16:37:21 +01:00
Code Issues Packages Projects Releases Wiki Activity

Fix prefetch support for asynchronous functions

Browse Source 
Fix #19
This commit is contained in:
Mariusz Nowak
2014-08-14 11:16:31 +02:00
parent a678982875
commit 168a9faf87
3 changed files with 97 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
ext/async.js
View File

@@ -49,7 +49,7 @@ require('../lib/registered-extensions').async = function (tbi, conf) {
var data;
if (hasOwnProperty.call(cache, id)) {
data = cache[id];
conf.emit('getasync', id);
conf.emit('getasync', id, args, context);
apply.call(cb, data.context, data.args);
} else {
// Purged in a meantime, we shouldn't rely on cached value, recall

8
ext/max-age.js
View File

@@ -2,7 +2,9 @@
'use strict';
var forEach = require('es5-ext/object/for-each')
var aFrom = require('es5-ext/array/from')
, noop = require('es5-ext/function/noop')
, forEach = require('es5-ext/object/for-each')
, timeout = require('timers-ext/valid-timeout')
, extensions = require('../lib/registered-extensions')
@@ -46,6 +48,10 @@ extensions.maxAge = function (maxAge, conf, options) {
preFetchTimeouts[id] = setTimeout(function () {
delete preFetchTimeouts[id];
conf.delete(id);
if (options.async) {
args = aFrom(args);
args.push(noop);
}
conf.memoized.apply(context, args);
}, 0);
}

89
test/ext/max-age.js
View File

@@ -265,6 +265,95 @@ module.exports = function () {
}, 200);
}, 300);
},
"Async": function (a, d) {
var mfn, fn, i = 0;
fn = function (x, y, cb) {
++i;
setTimeout(function () { cb(null, x + y); }, 0);
};
mfn = memoize(fn, { maxAge: 600, preFetch: true, async: true });
mfn(3, 7, function (err, result) {
a(result, 10, "Result #1");
a(i, 1, "Called #1");
mfn(3, 7, function (err, result) {
a(result, 10, "Result #2");
a(i, 1, "Called #2");
mfn(5, 8, function (err, result) {
a(result, 13, "Result B #1");
a(i, 2, "Called B #1");
mfn(3, 7, function (err, result) {
a(result, 10, "Result #3");
a(i, 2, "Called #3");
mfn(5, 8, function (err, result) {
a(result, 13, "Result B #2");
a(i, 2, "Called B #2");
setTimeout(function () {
mfn(3, 7, function (err, result) {
a(result, 10, "Result: Wait");
a(i, 2, "Called: Wait");
mfn(5, 8, function (err, result) {
a(result, 13, "Result: Wait B");
a(i, 2, "Called: Wait B");
setTimeout(function () {
mfn(3, 7, function (err, result) {
a(result, 10, "Result: Wait After");
a(i, 2, "Called: Wait After");
mfn(5, 8, function (err, result) {
a(result, 13, "Result: Wait After B");
a(i, 2, "Called: Wait After B");
mfn(3, 7, function (err, result) {
a(result, 10, "Result: Wait After #2");
a(i, 2, "Called: Wait After #2");
mfn(5, 8, function (err, result) {
a(result, 13, "Result: Wait After B #2");
a(i, 2, "Called: Wait After B #2");
setTimeout(function () {
a(i, 4, "Called: After Refetch: Before");
mfn(3, 7, function (err, result) {
a(result, 10, "Result: After Refetch");
a(i, 4, "Called: After Refetch: After");
mfn(5, 8, function (err, result) {
a(result, 13, "Result: After Refetch B");
a(i, 4, "Called: After Refetch B: After");
setTimeout(function () {
mfn(3, 7, function (err, result) {
a(result, 10, "Result: After Refetch #2");
a(i, 4, "Called: After Refetch #2");
mfn(5, 8, function (err, result) {
a(result, 13, "Result: After Refetch #2 B");
a(i, 4, "Called: After Refetch #2 B");
mfn(3, 7, function (err, result) {
a(result, 10, "Result: After Refetch #3");
a(i, 4, "Called: After Refetch #3");
mfn(5, 8, function (err, result) {
a(result, 13, "Result: After Refetch #3 B");
a(i, 4, "Called: After Refetch #3 B");
d();
});
});
});
});
}, 200);
});
});
}, 200);
});
});
});
});
}, 200);
});
});
}, 300);
});
});
});
});
});
},
"Custom": function (a, d) {
var mfn, fn, i = 0;
fn = function (x, y) {