+7
-0
@@ -6,5 +6,12 @@ "use strict"; | ||
| let element = undefined; | ||
| let containsPromise = false; | ||
| while (!(element = iterator.next()).done) { | ||
| if (element.value instanceof Promise) { | ||
| containsPromise = true; | ||
| } | ||
| elements.push(element.value); | ||
| } | ||
| if (containsPromise) { | ||
| return Promise.all(elements); | ||
| } | ||
| return elements; | ||
@@ -11,0 +18,0 @@ } |
+1
-1
@@ -1,1 +0,1 @@ | ||
| {"version":3,"file":"all.js","sourceRoot":"","sources":["../src/all.ts"],"names":[],"mappings":";;AAAA,aAAuB,QAA6B;IAChD,IAAI,QAAQ,GAAG,EAAE,CAAA;IACjB,IAAI,OAAO,GAAG,SAAS,CAAC;IACxB,OAAM,CAAC,CAAC,OAAO,GAAC,QAAQ,CAAC,IAAI,EAAE,CAAC,CAAC,IAAI,EAAC,CAAC;QACnC,QAAQ,CAAC,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,CAAC;IACjC,CAAC;IACD,MAAM,CAAC,QAAQ,CAAC;AACpB,CAAC;AAPD,kBAOC"} | ||
| {"version":3,"file":"all.js","sourceRoot":"","sources":["../src/all.ts"],"names":[],"mappings":";;AAAA,aAAuB,QAA6B;IAChD,IAAI,QAAQ,GAAG,EAAE,CAAA;IACjB,IAAI,OAAO,GAAG,SAAS,CAAC;IACxB,IAAI,eAAe,GAAG,KAAK,CAAC;IAC5B,OAAM,CAAC,CAAC,OAAO,GAAC,QAAQ,CAAC,IAAI,EAAE,CAAC,CAAC,IAAI,EAAC,CAAC;QACnC,EAAE,CAAA,CAAC,OAAO,CAAC,KAAK,YAAY,OAAO,CAAC,CAAA,CAAC;YACjC,eAAe,GAAG,IAAI,CAAC;QAC3B,CAAC;QACD,QAAQ,CAAC,IAAI,CAAC,OAAO,CAAC,KAAK,CAAC,CAAC;IACjC,CAAC;IACD,EAAE,CAAA,CAAC,eAAe,CAAC,CAAA,CAAC;QAChB,MAAM,CAAC,OAAO,CAAC,GAAG,CAAC,QAAQ,CAAC,CAAC;IACjC,CAAC;IACD,MAAM,CAAC,QAAQ,CAAC;AACpB,CAAC;AAdD,kBAcC"} |
+6
-10
@@ -6,15 +6,11 @@ "use strict"; | ||
| while (!(element = data.next()).done) { | ||
| consumer(element.value); | ||
| if (element.value instanceof Promise) { | ||
| return element.value.then(v => consumer(v)); | ||
| } | ||
| else { | ||
| consumer(element.value); | ||
| } | ||
| } | ||
| } | ||
| exports.each = each; | ||
| function eachAsync(data, consumer) { | ||
| let promises = []; | ||
| let element = undefined; | ||
| while (!(element = data.next()).done) { | ||
| promises.push(consumer(element.value)); | ||
| } | ||
| return Promise.all(promises).then(() => { }); | ||
| } | ||
| exports.eachAsync = eachAsync; | ||
| //# sourceMappingURL=each.js.map |
+1
-1
@@ -1,1 +0,1 @@ | ||
| {"version":3,"file":"each.js","sourceRoot":"","sources":["../src/each.ts"],"names":[],"mappings":";;AAAA,cAAwB,IAAyB,EAAE,QAA8B;IAC7E,IAAI,OAAO,GAAG,SAAS,CAAC;IACxB,OAAO,CAAC,CAAC,OAAO,GAAG,IAAI,CAAC,IAAI,EAAE,CAAC,CAAC,IAAI,EAAE,CAAC;QACnC,QAAQ,CAAC,OAAO,CAAC,KAAK,CAAC,CAAC;IAC5B,CAAC;AACL,CAAC;AALD,oBAKC;AAGD,mBAA6B,IAAyB,EAAE,QAAuC;IAC3F,IAAI,QAAQ,GAAoB,EAAE,CAAC;IACnC,IAAI,OAAO,GAAG,SAAS,CAAC;IACxB,OAAO,CAAC,CAAC,OAAO,GAAG,IAAI,CAAC,IAAI,EAAE,CAAC,CAAC,IAAI,EAAE,CAAC;QAClC,QAAQ,CAAC,IAAI,CAAC,QAAQ,CAAC,OAAO,CAAC,KAAK,CAAC,CAAC,CAAC;IAC5C,CAAC;IACD,MAAM,CAAC,OAAO,CAAC,GAAG,CAAC,QAAQ,CAAC,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC,CAAC;AACjD,CAAC;AAPD,8BAOC"} | ||
| {"version":3,"file":"each.js","sourceRoot":"","sources":["../src/each.ts"],"names":[],"mappings":";;AAAA,cAAwB,IAAyB,EAAE,QAA8B;IAC7E,IAAI,OAAO,GAAG,SAAS,CAAC;IACxB,OAAO,CAAC,CAAC,OAAO,GAAG,IAAI,CAAC,IAAI,EAAE,CAAC,CAAC,IAAI,EAAE,CAAC;QACnC,EAAE,CAAA,CAAC,OAAO,CAAC,KAAK,YAAY,OAAO,CAAC,CAAA,CAAC;YACjC,MAAM,CAAC,OAAO,CAAC,KAAK,CAAC,IAAI,CAAC,CAAC,IAAE,QAAQ,CAAC,CAAC,CAAC,CAAC,CAAC;QAC9C,CAAC;QACD,IAAI,CAAA,CAAC;YACD,QAAQ,CAAC,OAAO,CAAC,KAAK,CAAC,CAAC;QAC5B,CAAC;IACL,CAAC;AACL,CAAC;AAVD,oBAUC"} |
+5
-17
@@ -7,11 +7,11 @@ "use strict"; | ||
| const first_1 = require("./first"); | ||
| class AsyncFnp { | ||
| class Fnp { | ||
| constructor(iterator) { | ||
| this.iterator = iterator; | ||
| } | ||
| eachAsync(consumer) { | ||
| return each_1.eachAsync(this.iterator, consumer); | ||
| each(consumer) { | ||
| return each_1.each(this.iterator, consumer); | ||
| } | ||
| mapAsync(predicate) { | ||
| return map_1.mapAsync(this.iterator, predicate); | ||
| map(predicate) { | ||
| return map_1.map(this.iterator, predicate); | ||
| } | ||
@@ -25,14 +25,2 @@ first() { | ||
| } | ||
| exports.AsyncFnp = AsyncFnp; | ||
| class Fnp extends AsyncFnp { | ||
| constructor(iterator) { | ||
| super(iterator); | ||
| } | ||
| each(consumer) { | ||
| each_1.each(this.iterator, consumer); | ||
| } | ||
| map(predicate) { | ||
| return map_1.map(this.iterator, predicate); | ||
| } | ||
| } | ||
| exports.Fnp = Fnp; | ||
@@ -39,0 +27,0 @@ function fnp(data) { |
+1
-1
@@ -1,1 +0,1 @@ | ||
| {"version":3,"file":"fnp.js","sourceRoot":"","sources":["../src/fnp.ts"],"names":[],"mappings":";;AAAA,+BAA4B;AAC5B,iCAAyC;AACzC,+BAAsC;AACtC,mCAAgC;AAEhC;IACI,YAAsB,QAA6B;QAA7B,aAAQ,GAAR,QAAQ,CAAqB;IACnD,CAAC;IAED,SAAS,CAAC,QAAuC;QAC7C,MAAM,CAAC,gBAAS,CAAC,IAAI,CAAC,QAAQ,EAAE,QAAQ,CAAC,CAAC;IAC9C,CAAC;IAED,QAAQ,CAAI,SAAqC;QAC7C,MAAM,CAAC,cAAQ,CAAC,IAAI,CAAC,QAAQ,EAAE,SAAS,CAAC,CAAC;IAC9C,CAAC;IAED,KAAK;QACD,MAAM,CAAC,aAAK,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;IAChC,CAAC;IAED,GAAG;QACC,MAAM,CAAC,SAAG,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;IAC9B,CAAC;CACJ;AAnBD,4BAmBC;AAED,SAAoB,SAAQ,QAAW;IAEnC,YAAY,QAA6B;QACrC,KAAK,CAAC,QAAQ,CAAC,CAAC;IACpB,CAAC;IAED,IAAI,CAAC,QAA8B;QAC/B,WAAI,CAAC,IAAI,CAAC,QAAQ,EAAE,QAAQ,CAAC,CAAC;IAClC,CAAC;IAED,GAAG,CAAI,SAA4B;QAC/B,MAAM,CAAC,SAAG,CAAC,IAAI,CAAC,QAAQ,EAAE,SAAS,CAAC,CAAC;IACzC,CAAC;CACJ;AAbD,kBAaC;AAKD,aAAuB,IAAiB;IACpC;QACI,GAAG,CAAC,CAAC,IAAI,OAAO,IAAI,IAAI,CAAC,CAAC,CAAC;YACvB,MAAM,OAAO,CAAC;QAClB,CAAC;IACL,CAAC;IACD,MAAM,CAAC,IAAI,GAAG,CAAI,OAAO,EAAE,CAAC,CAAC;AACjC,CAAC;AAPD,kBAOC;AAED,kBAAe,GAAG,CAAC"} | ||
| {"version":3,"file":"fnp.js","sourceRoot":"","sources":["../src/fnp.ts"],"names":[],"mappings":";;AAAA,+BAA4B;AAC5B,iCAA8B;AAC9B,+BAA4B;AAC5B,mCAAgC;AAGhC;IAEI,YAAoB,QAA6B;QAA7B,aAAQ,GAAR,QAAQ,CAAqB;IAAG,CAAC;IAErD,IAAI,CAAC,QAA8B;QAC/B,MAAM,CAAC,WAAI,CAAC,IAAI,CAAC,QAAQ,EAAE,QAAQ,CAAC,CAAC;IACzC,CAAC;IAED,GAAG,CAAI,SAAuC;QAC1C,MAAM,CAAC,SAAG,CAAC,IAAI,CAAC,QAAQ,EAAE,SAAS,CAAC,CAAC;IACzC,CAAC;IAED,KAAK;QACD,MAAM,CAAC,aAAK,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;IAChC,CAAC;IAED,GAAG;QACC,MAAM,CAAC,SAAG,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;IAC9B,CAAC;CACJ;AAnBD,kBAmBC;AAKD,aAAuB,IAAiB;IACpC;QACI,GAAG,CAAC,CAAC,IAAI,OAAO,IAAI,IAAI,CAAC,CAAC,CAAC;YACvB,MAAM,OAAO,CAAC;QAClB,CAAC;IACL,CAAC;IACD,MAAM,CAAC,IAAI,GAAG,CAAI,OAAO,EAAE,CAAC,CAAC;AACjC,CAAC;AAPD,kBAOC;AAED,kBAAe,GAAG,CAAC"} |
+6
-11
@@ -8,3 +8,8 @@ "use strict"; | ||
| while (!(element = iterator.next()).done) { | ||
| yield predicate(element.value); | ||
| if (element.value instanceof Promise) { | ||
| yield element.value.then(v => predicate(v)); | ||
| } | ||
| else { | ||
| yield predicate(element.value); | ||
| } | ||
| } | ||
@@ -15,12 +20,2 @@ } | ||
| exports.map = map; | ||
| function mapAsync(iterator, predicate) { | ||
| function* mapIterator() { | ||
| let element = undefined; | ||
| while (!(element = iterator.next()).done) { | ||
| yield predicate(element.value); | ||
| } | ||
| } | ||
| return new fnp_1.AsyncFnp(mapIterator()); | ||
| } | ||
| exports.mapAsync = mapAsync; | ||
| //# sourceMappingURL=map.js.map |
+1
-1
@@ -1,1 +0,1 @@ | ||
| {"version":3,"file":"map.js","sourceRoot":"","sources":["../src/map.ts"],"names":[],"mappings":";;AAAA,+BAAsC;AAGtC,aAAyB,QAA6B,EAAE,SAA0B;IAC9E;QACI,IAAI,OAAO,GAAG,SAAS,CAAC;QACxB,OAAM,CAAC,CAAC,OAAO,GAAG,QAAQ,CAAC,IAAI,EAAE,CAAC,CAAC,IAAI,EAAC,CAAC;YACrC,MAAM,SAAS,CAAC,OAAO,CAAC,KAAK,CAAC,CAAC;QACnC,CAAC;IACL,CAAC;IACD,MAAM,CAAC,IAAI,SAAG,CAAI,WAAW,EAAE,CAAC,CAAC;AACrC,CAAC;AARD,kBAQC;AAED,kBAA8B,QAA6B,EAAE,SAAmC;IAC5F;QACI,IAAI,OAAO,GAAG,SAAS,CAAC;QACxB,OAAM,CAAC,CAAC,OAAO,GAAG,QAAQ,CAAC,IAAI,EAAE,CAAC,CAAC,IAAI,EAAC,CAAC;YACrC,MAAM,SAAS,CAAC,OAAO,CAAC,KAAK,CAAC,CAAC;QACnC,CAAC;IACL,CAAC;IACD,MAAM,CAAC,IAAI,cAAQ,CAAC,WAAW,EAAE,CAAC,CAAC;AACvC,CAAC;AARD,4BAQC"} | ||
| {"version":3,"file":"map.js","sourceRoot":"","sources":["../src/map.ts"],"names":[],"mappings":";;AAAA,+BAA2B;AAG3B,aAAyB,QAA6B,EAAE,SAAqC;IACzF;QACI,IAAI,OAAO,GAAG,SAAS,CAAC;QACxB,OAAM,CAAC,CAAC,OAAO,GAAG,QAAQ,CAAC,IAAI,EAAE,CAAC,CAAC,IAAI,EAAC,CAAC;YACrC,EAAE,CAAA,CAAC,OAAO,CAAC,KAAK,YAAY,OAAO,CAAC,CAAA,CAAC;gBACjC,MAAM,OAAO,CAAC,KAAK,CAAC,IAAI,CAAC,CAAC,IAAE,SAAS,CAAM,CAAC,CAAC,CAAC,CAAC;YACnD,CAAC;YACD,IAAI,CAAA,CAAC;gBACD,MAAM,SAAS,CAAC,OAAO,CAAC,KAAK,CAAC,CAAC;YACnC,CAAC;QAEL,CAAC;IACL,CAAC;IACD,MAAM,CAAC,IAAI,SAAG,CAAC,WAAW,EAAE,CAAC,CAAC;AAClC,CAAC;AAdD,kBAcC"} |
+2
-2
| { | ||
| "name": "fnp", | ||
| "version": "0.0.6", | ||
| "version": "0.0.7", | ||
| "description": "(async) Functional programming", | ||
@@ -13,4 +13,4 @@ "main": "dist/fnp.js", | ||
| "devDependencies": { | ||
| "typescript": "^2.2.1" | ||
| "typescript": "^2.3.0-dev.20170223" | ||
| } | ||
| } |
7117
-8.4%123
-10.22%