| Server IP : 68.183.124.220 / Your IP : 216.73.217.137 Web Server : Apache/2.4.18 (Ubuntu) System : Linux Sandbox-A 4.4.0-210-generic #242-Ubuntu SMP Fri Apr 16 09:57:56 UTC 2021 x86_64 User : gavin ( 1000) PHP Version : 7.0.33-0ubuntu0.16.04.16 Disable Function : pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wifcontinued,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority, MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : ON Directory : /home/gavin/workspace/happymandarin/node_modules/pend/ |
Upload File : |
var assert = require('assert');
var Pend = require('./');
var tests = [
{
name: "basic",
fn: testBasic,
},
{
name: "max",
fn: testWithMax,
},
{
name: "callback twice",
fn: testCallbackTwice,
},
{
name: "calling wait twice",
fn: testCallingWaitTwice,
},
{
name: "hold()",
fn: testHoldFn,
},
];
var testCount = tests.length;
doOneTest();
function doOneTest() {
var test = tests.shift();
if (!test) {
console.log(testCount + " tests passed.");
return;
}
process.stdout.write(test.name + "...");
test.fn(function() {
process.stdout.write("OK\n");
doOneTest();
});
}
function testBasic(cb) {
var pend = new Pend();
var results = [];
pend.go(function(cb) {
results.push(1);
setTimeout(function() {
results.push(3);
cb();
}, 500);
});
pend.go(function(cb) {
results.push(2);
setTimeout(function() {
results.push(4);
cb();
}, 1000);
});
pend.wait(function(err) {
assert.deepEqual(results, [1,2,3,4]);
cb();
});
assert.deepEqual(results, [1, 2]);
}
function testWithMax(cb) {
var pend = new Pend();
var results = [];
pend.max = 2;
pend.go(function(cb) {
results.push('a');
setTimeout(function() {
results.push(1);
cb();
}, 500);
});
pend.go(function(cb) {
results.push('b');
setTimeout(function() {
results.push(1);
cb();
}, 500);
});
pend.go(function(cb) {
results.push('c');
setTimeout(function() {
results.push(2);
cb();
}, 100);
});
pend.wait(function(err) {
assert.deepEqual(results, ['a', 'b', 1, 'c', 1, 2]);
cb();
});
assert.deepEqual(results, ['a', 'b']);
}
function testCallbackTwice(cb) {
var pend = new Pend();
pend.go(function(cb) {
setTimeout(cb, 100);
});
pend.go(function(cb) {
cb();
assert.throws(cb, /callback called twice/);
});
pend.wait(cb);
}
function testCallingWaitTwice(cb) {
var pend = new Pend();
pend.go(function(cb) {
setTimeout(cb, 100);
});
pend.wait(function() {
pend.go(function(cb) {
setTimeout(cb, 50);
});
pend.go(function(cb) {
setTimeout(cb, 10);
});
pend.go(function(cb) {
setTimeout(cb, 20);
});
pend.wait(cb);
});
}
function testHoldFn(cb) {
var pend = new Pend();
setTimeout(pend.hold(), 100);
pend.go(function(cb) {
cb();
});
pend.wait(cb);
}