Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More →
async-await
Advanced tools
async-await - npm Package Compare versions
Comparing version 0.1.23 to 0.1.24
| { | ||
| "name": "async-await", | ||
| "version": "0.1.23", | ||
| "version": "0.1.24", | ||
| "description": "aa - async-await. co like library, go like channel, thunkify or promisify wrap package.", | ||
@@ -5,0 +5,0 @@ "main": "aa.js", |
322
README.md
@@ -137,6 +137,6 @@ [aa](https://www.npmjs.com/package/aa) - [async-await](https://www.npmjs.com/package/async-await) | ||
| // asyncPromise(ms, arg) : promise | ||
| function asyncPromise(ms, arg) { | ||
| return new Promise(function (res, rej) { | ||
| setTimeout(function () { res(arg); }, ms); | ||
| // asyncPromise(msec, arg) : promise | ||
| function asyncPromise(msec, arg) { | ||
| return new Promise(function (resolve, reject) { | ||
| setTimeout(resolve, msec, arg); | ||
| }); | ||
@@ -146,6 +146,6 @@ } | ||
| // asyncThunk(ms, arg) : thunk | ||
| function asyncThunk(ms, arg) { | ||
| return function (cb) { | ||
| setTimeout(function () { cb(null, arg); }, ms); | ||
| // asyncThunk(msec, arg) : thunk | ||
| function asyncThunk(msec, arg) { | ||
| return function (callback) { | ||
| setTimeout(callback, msec, null, arg); | ||
| }; | ||
@@ -155,6 +155,6 @@ } | ||
| // asyncGenerator(ms, arg) : generator | ||
| function *asyncGenerator(ms, arg) { | ||
| // asyncGenerator(msec, arg) : generator | ||
| function *asyncGenerator(msec, arg) { | ||
| var chan = aa.Channel(); | ||
| setTimeout(function () { chan(arg); }, ms); | ||
| setTimeout(chan, msec, arg); | ||
| return yield chan; | ||
@@ -202,6 +202,6 @@ } | ||
| // asyncPromise(ms, arg) : promise | ||
| function asyncPromise(ms, arg) { | ||
| return new Promise(function (res, rej) { | ||
| setTimeout(function () { res(arg); }, ms); | ||
| // asyncPromise(msec, arg) : promise | ||
| function asyncPromise(msec, arg) { | ||
| return new Promise(function (resolve, reject) { | ||
| setTimeout(resolve, msec, arg); | ||
| }); | ||
@@ -211,6 +211,6 @@ } | ||
| // asyncThunk(ms, arg) : thunk | ||
| function asyncThunk(ms, arg) { | ||
| return function (cb) { | ||
| setTimeout(function () { cb(null, arg); }, ms); | ||
| // asyncThunk(msec, arg) : thunk | ||
| function asyncThunk(msec, arg) { | ||
| return function (callback) { | ||
| setTimeout(callback, msec, null, arg); | ||
| }; | ||
@@ -220,6 +220,6 @@ } | ||
| // asyncGenerator(ms, arg) : generator | ||
| function *asyncGenerator(ms, arg) { | ||
| // asyncGenerator(msec, arg) : generator | ||
| function *asyncGenerator(msec, arg) { | ||
| var chan = aa.Channel(); | ||
| setTimeout(function () { chan(arg); }, ms); | ||
| setTimeout(chan, msec, arg); | ||
| return yield chan; | ||
@@ -265,6 +265,6 @@ } | ||
| // asyncCallback(ms, arg. cb) : node style normal callback | ||
| // cb : function (err, val) | ||
| function asyncCallback(ms, arg, cb) { | ||
| setTimeout(function () { cb(null, arg); }, ms); | ||
| // asyncCallback(msec, arg. callback) : node style normal callback | ||
| // callback : function (err, val) | ||
| function asyncCallback(msec, arg, callback) { | ||
| setTimeout(callback, msec, null, arg); | ||
| } | ||
@@ -309,6 +309,6 @@ ``` | ||
| // asyncCallback(ms, arg. cb) : node style normal callback | ||
| // cb : function (err, val) | ||
| function asyncCallback(ms, arg, cb) { | ||
| setTimeout(function () { cb(null, arg); }, ms); | ||
| // asyncCallback(msec, arg. callback) : node style normal callback | ||
| // callback : function (err, val) | ||
| function asyncCallback(msec, arg, callback) { | ||
| setTimeout(callback, msec, null, arg); | ||
| } | ||
@@ -329,170 +329,172 @@ ``` | ||
| // sleep(ms, args,... cb) : node style normal callback | ||
| function sleep(ms) { | ||
| var args = [].slice.call(arguments, 1); | ||
| setTimeout.apply(null, [args.pop(), ms, null].concat(args)); | ||
| } | ||
| // sleep(msec, args,... callback) : node style normal callback | ||
| // callback : function (err, val) | ||
| function sleep(msec) { | ||
| var args = [].slice.call(arguments, 1); | ||
| setTimeout.apply(null, [args.pop(), msec, null].concat(args)); | ||
| } | ||
| sleep(1000, function (err, val) { console.log('1000 ms OK'); }); | ||
| sleep(1000, function (err, val) { console.log('1000 msec OK'); }); | ||
| // delay(ms, args,...)(cb) : thunk | ||
| function delay(ms) { | ||
| var args = [].slice.call(arguments); | ||
| return function (cb) { | ||
| sleep.apply(null, args.concat(cb)); | ||
| }; | ||
| } | ||
| // var delay = aa.thunkify(sleep); | ||
| // delay(msec, args,...)(callback) : thunk | ||
| // callback : function (err, val) | ||
| function delay(msec) { | ||
| var args = [].slice.call(arguments); | ||
| return function (callback) { | ||
| sleep.apply(null, args.concat(callback)); | ||
| }; | ||
| } | ||
| // var delay = aa.thunkify(sleep); | ||
| delay(1100)( | ||
| function (err, val) { console.log('1100 ms OK'); } | ||
| ); | ||
| delay(1100)( | ||
| function (err, val) { console.log('1100 msec OK'); } | ||
| ); | ||
| // aa.promisify(fn) : returns wrapped function a.k.a thunkify and promisify | ||
| // wait(ms, args,...) : returns promise & thunk | ||
| var wait = aa.promisify(sleep); | ||
| // aa.promisify(fn) : returns wrapped function a.k.a thunkify and promisify | ||
| // wait(msec, args,...) : returns promise & thunk | ||
| var wait = aa.promisify(sleep); | ||
| // wait() : as a thunk | ||
| wait(1200)( | ||
| function (err, val) { console.log('1200 ms OK'); } | ||
| ); | ||
| // wait() : as a thunk | ||
| wait(1200)( | ||
| function (err, val) { console.log('1200 msec OK'); } | ||
| ); | ||
| // wait() : as a promise | ||
| wait(1300).then( | ||
| function (val) { console.log('1300 ms OK'); }, | ||
| function (err) { console.log('1300 ms NG', err); } | ||
| ).catch( | ||
| function (err) { console.log('1300 ms NG2', err); } | ||
| ); | ||
| // wait() : as a promise | ||
| wait(1300).then( | ||
| function (val) { console.log('1300 msec OK'); }, | ||
| function (err) { console.log('1300 msec NG', err); } | ||
| ).catch( | ||
| function (err) { console.log('1300 msec NG2', err); } | ||
| ); | ||
| // aa(generator) : returns promise & thunk | ||
| aa(function *() { | ||
| // aa(generator) : returns promise & thunk | ||
| aa(function *() { | ||
| yield 1; // primitive value | ||
| yield [1, 2, 3]; // array | ||
| yield {x:1, y:2, z:3}; // object | ||
| yield 1; // primitive value | ||
| yield [1, 2, 3]; // array | ||
| yield {x:1, y:2, z:3}; // object | ||
| // wait for promise | ||
| yield Promise.resolve(2); | ||
| // wait for promise | ||
| yield Promise.resolve(2); | ||
| // wait for thunk | ||
| yield delay(800); | ||
| // wait for thunk | ||
| yield delay(800); | ||
| // wait for promise or thunk | ||
| yield wait(800); | ||
| // wait for promise or thunk | ||
| yield wait(800); | ||
| console.log('0:', yield wait(300, 0)); | ||
| console.log('1:', yield wait(300, 1)); | ||
| console.log('0:', yield wait(300, 0)); | ||
| console.log('1:', yield wait(300, 1)); | ||
| // yield Promise.all([]) | ||
| console.log('[1, 2, 3]:', | ||
| yield Promise.all([wait(200, 1), wait(300, 2), wait(100, 3)])); | ||
| // yield Promise.all([]) | ||
| console.log('[1, 2, 3]:', | ||
| yield Promise.all([wait(200, 1), wait(300, 2), wait(100, 3)])); | ||
| // yield [] -> like Promise.all([]) ! | ||
| console.log('[4, 5, 6]:', | ||
| yield [wait(200, 4), wait(300, 5), wait(100, 6)]); | ||
| // yield [] -> like Promise.all([]) ! | ||
| console.log('[4, 5, 6]:', | ||
| yield [wait(200, 4), wait(300, 5), wait(100, 6)]); | ||
| // yield {} -> like Promise.all({}) !? | ||
| console.log('{x:7, y:8, z:9}:', | ||
| yield {x:wait(200, 7), y:wait(300, 8), z:wait(100, 9)}); | ||
| // yield {} -> like Promise.all({}) !? | ||
| console.log('{x:7, y:8, z:9}:', | ||
| yield {x:wait(200, 7), y:wait(300, 8), z:wait(100, 9)}); | ||
| // make channel for sync - fork and join | ||
| var chan = aa.Channel(); | ||
| // make channel for sync - fork and join | ||
| var chan = aa.Channel(); | ||
| sleep(300, 20, chan); // send value to channel : fork or spread | ||
| sleep(200, 10, chan); // send value to channel : fork or spread | ||
| var a = yield chan; // recv value from channel : join or sync | ||
| var b = yield chan; // recv value from channel : join or sync | ||
| console.log('10 20:', a, b); | ||
| sleep(300, 20, chan); // send value to channel : fork or spread | ||
| sleep(200, 10, chan); // send value to channel : fork or spread | ||
| var a = yield chan; // recv value from channel : join or sync | ||
| var b = yield chan; // recv value from channel : join or sync | ||
| console.log('10 20:', a, b); | ||
| // fork thread - make new thread and start | ||
| aa(function *() { | ||
| yield wait(200); // wait 200 ms | ||
| return 200; | ||
| })(chan); // send 200 to channel : join or sync | ||
| // fork thread - make new thread and start | ||
| aa(function *() { | ||
| yield wait(200); // wait 200 msec | ||
| return 200; | ||
| })(chan); // send 200 to channel : join or sync | ||
| // fork thread - make new thread and start | ||
| aa(function *() { | ||
| yield wait(100); // wait 100 ms | ||
| return 100; | ||
| })(chan); // send 100 to channel : join or sync | ||
| // fork thread - make new thread and start | ||
| aa(function *() { | ||
| yield wait(100); // wait 100 msec | ||
| return 100; | ||
| })(chan); // send 100 to channel : join or sync | ||
| // fork thread - make new thread and start | ||
| aa(function *() { | ||
| yield wait(300); // wait 300 | ||
| return 300; | ||
| })(chan); // send 300 to channel : join or sync | ||
| // fork thread - make new thread and start | ||
| aa(function *() { | ||
| yield wait(300); // wait 300 | ||
| return 300; | ||
| })(chan); // send 300 to channel : join or sync | ||
| // join threads - sync threads | ||
| var x = yield chan; // wait & recv first value from channel | ||
| var y = yield chan; // wait & recv second value from channel | ||
| var z = yield chan; // wait & recv third value from channel | ||
| console.log('top 3 winners: 100 200 300:', x, y, z); | ||
| // join threads - sync threads | ||
| var x = yield chan; // wait & recv first value from channel | ||
| var y = yield chan; // wait & recv second value from channel | ||
| var z = yield chan; // wait & recv third value from channel | ||
| console.log('top 3 winners: 100 200 300:', x, y, z); | ||
| // communicate with channels | ||
| var chan1 = aa.Channel(), chan2 = aa.Channel(); | ||
| // communicate with channels | ||
| var chan1 = aa.Channel(), chan2 = aa.Channel(); | ||
| // thread 1: send to chan1, recv from chan2 | ||
| aa(function *() { | ||
| sleep(100, 111, chan1); | ||
| console.log('222:', yield chan2); | ||
| sleep(100, 333, chan1); | ||
| console.log('444:', yield chan2); | ||
| sleep(100, 555, chan1); | ||
| return 666; | ||
| })(chan); | ||
| // thread 1: send to chan1, recv from chan2 | ||
| aa(function *() { | ||
| sleep(100, 111, chan1); | ||
| console.log('222:', yield chan2); | ||
| sleep(100, 333, chan1); | ||
| console.log('444:', yield chan2); | ||
| sleep(100, 555, chan1); | ||
| return 666; | ||
| })(chan); | ||
| // thread 1: recv from chan1, send to chan2 | ||
| aa(function *() { | ||
| console.log('111:', yield chan1); | ||
| sleep(100, 222, chan2); | ||
| console.log('333:', yield chan1); | ||
| sleep(100, 444, chan2); | ||
| console.log('555:', yield chan1); | ||
| return 777; | ||
| })(chan); | ||
| console.log('666 777:', yield chan, yield chan); | ||
| // thread 1: recv from chan1, send to chan2 | ||
| aa(function *() { | ||
| console.log('111:', yield chan1); | ||
| sleep(100, 222, chan2); | ||
| console.log('333:', yield chan1); | ||
| sleep(100, 444, chan2); | ||
| console.log('555:', yield chan1); | ||
| return 777; | ||
| })(chan); | ||
| console.log('666 777:', yield chan, yield chan); | ||
| return 11; | ||
| }) | ||
| .then( | ||
| function (val) { | ||
| console.log('11 val:', val); | ||
| return wait(100, 22); }, | ||
| function (err) { | ||
| console.log('11 err:', err); | ||
| return wait(100, 22); } | ||
| ) | ||
| (function (err, val) { | ||
| console.log('22 val:', val, err ? 'err:' + err : ''); | ||
| return wait(100, 33); }) | ||
| (function (err, val) { | ||
| console.log('33 val:', val, err ? 'err:' + err : ''); | ||
| return wait(100, 44); }) | ||
| .then( | ||
| function (val) { | ||
| console.log('44 val:', val); | ||
| return wait(100, 55); }, | ||
| function (err) { | ||
| console.log('44 err:', err); | ||
| return wait(100, 55); } | ||
| ) | ||
| .catch( | ||
| function (err) { | ||
| console.log('55 err:', err); | ||
| return wait(100, 66); } | ||
| ); | ||
| return 11; | ||
| }) | ||
| .then( | ||
| function (val) { | ||
| console.log('11 val:', val); | ||
| return wait(100, 22); }, | ||
| function (err) { | ||
| console.log('11 err:', err); | ||
| return wait(100, 22); } | ||
| ) | ||
| (function (err, val) { | ||
| console.log('22 val:', val, err ? 'err:' + err : ''); | ||
| return wait(100, 33); }) | ||
| (function (err, val) { | ||
| console.log('33 val:', val, err ? 'err:' + err : ''); | ||
| return wait(100, 44); }) | ||
| .then( | ||
| function (val) { | ||
| console.log('44 val:', val); | ||
| return wait(100, 55); }, | ||
| function (err) { | ||
| console.log('44 err:', err); | ||
| return wait(100, 55); } | ||
| ) | ||
| .catch( | ||
| function (err) { | ||
| console.log('55 err:', err); | ||
| return wait(100, 66); } | ||
| ); | ||
| ``` | ||
@@ -499,0 +501,0 @@ |
New alerts
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
Fixed alerts
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
Improved metrics
- Number of lines in readme file
- increased by0.4%
498
Worsened metrics
- Total package byte prevSize
- decreased by-0.58%
22957
No dependency changes