67 lines
1.7 KiB
JavaScript
67 lines
1.7 KiB
JavaScript
var gen = require('./index.js');
|
|
|
|
function* test()
|
|
{
|
|
console.log('start');
|
|
// Should give no "Generator is already running" error
|
|
var v = yield gen.cb()('expected value');
|
|
console.log(v[0] === 'expected value');
|
|
var cb = gen.unsafe();
|
|
console.log([ 'next', yield setTimeout(function() { cb('zhopa', 123); }, 500) ]);
|
|
var args = yield gen.runParallel([
|
|
(function*()
|
|
{
|
|
var cb = gen.unsafe();
|
|
yield setTimeout(function() { cb('callback 1'); }, 500);
|
|
return 'result 1';
|
|
})(),
|
|
(function*()
|
|
{
|
|
var cb = gen.unsafe();
|
|
yield setTimeout(function() { cb('callback 2'); }, 500);
|
|
return 'result 2';
|
|
})()
|
|
], gen.cb());
|
|
console.log('abc');
|
|
console.log(args);
|
|
return 'result';
|
|
}
|
|
|
|
function* test_throttle()
|
|
{
|
|
yield gen.throttle(5);
|
|
console.log('at most 5');
|
|
yield setTimeout(gen.cb(), 1000);
|
|
console.log('continue in another generator');
|
|
yield* other_gen(); // same as 'yield gen.run(other_gen, gen.cb())'
|
|
}
|
|
|
|
function* other_gen()
|
|
{
|
|
yield setTimeout(gen.cb(), 1000);
|
|
console.log('finished in another generator');
|
|
}
|
|
|
|
function* test_throw()
|
|
{
|
|
var cb = gen.errorfirst();
|
|
try
|
|
{
|
|
yield setTimeout(function() { cb(new Error()); }, 500);
|
|
}
|
|
catch (e)
|
|
{
|
|
console.log('Catched '+e.stack);
|
|
}
|
|
console.log(yield setTimeout(gen.cb(), 500));
|
|
console.log('sleep');
|
|
console.log(yield setTimeout(gen.cb(), 500));
|
|
console.log('continue');
|
|
}
|
|
|
|
gen.run(test, function(result) { console.log(result); });
|
|
|
|
for (var i = 0; i < 15; i++) gen.run(test_throttle);
|
|
|
|
gen.run(test_throw);
|