Initial commit

Author: developit

.babelrc

@@ -0,0 +1,9 @@
+{
+	"presets": [
+		["es2015", {"loose":true}],
+		"stage-0"
+	],
+	"plugins": [
+		["transform-react-jsx", {"pragma":"h"}]
+	]
+}

.gitignore

@@ -0,0 +1,4 @@
+/lib
+node_modules
+npm-debug.log
+.DS_Store

.travis.yml

@@ -0,0 +1,3 @@
+language: node_js
+node_js:
+  - stable

LICENSE

@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2016 Jason Miller
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

README.md

@@ -0,0 +1,22 @@
+# `asyncro` [![NPM](https://img.shields.io/npm/v/asyncro.svg?style=flat)](https://www.npmjs.org/package/asyncro) [![travis-ci](https://travis-ci.org/developit/asyncro.svg?branch=master)](https://travis-ci.org/developit/asyncro)
+
+Converts JSX to Objects (JSON) <sub>using blood magic</sub>.
+
+```sh
+npm install --save asyncro
+```
+
+---
+
+### Example
+
+```js
+import { map } from 'asyncro';
+
+async function example() {
+	await map(
+		['foo', 'bar'],
+		async name => fetch('./'+name)
+	)
+}
+```

package.json

@@ -0,0 +1,34 @@
+{
+  "name": "asyncro",
+  "version": "1.0.0",
+  "description": "Utilities for working with Arrays asynchronously.",
+  "main": "lib/index.js",
+  "jsnext:main": "src/index.js",
+  "scripts": {
+    "build": "babel src -d lib -s",
+    "prepublish": "npm run -s build && npm run -s test",
+    "test": "babel-node test",
+    "release": "npm run -s build && git commit -am $npm_package_version && git tag $npm_package_version && git push && git push --tags && npm publish"
+  },
+  "repository": {
+    "type": "git",
+    "url": "git+https://github.com/developit/asyncro.git"
+  },
+  "keywords": [
+    "async",
+    "await",
+    "arrays"
+  ],
+  "author": "Jason Miller <[email protected]>",
+  "license": "ISC",
+  "bugs": {
+    "url": "https://github.com/developit/asyncro/issues"
+  },
+  "homepage": "https://github.com/developit/asyncro",
+  "devDependencies": {
+    "babel-cli": "^6.14.0",
+    "babel-plugin-transform-react-jsx": "^6.8.0",
+    "babel-preset-es2015": "^6.14.0",
+    "babel-preset-stage-0": "^6.5.0"
+  }
+}

src/index.js

@@ -0,0 +1,61 @@
+/** Async version of Array.prototype.reduce()
+ *	await reduce(['/foo', '/bar', '/baz'], async (acc, v) => {
+ *		acc[v] = await (await fetch(v)).json();
+ *		return acc;
+ *	}, {});
+ */
+export async function reduce(arr, fn, val, pure) {
+	for (let i=0; i<arr.length; i++) {
+		let v = await fn(val, arr[i], i, arr);
+		if (pure!==false) val = v;
+	}
+	return val;
+}
+
+/** Async version of Array.prototype.map()
+ *	await map(['foo', 'baz'], async v => await fetch(v) )
+ */
+export async function map(arr, fn) {
+	return await reduce(arr, async (acc, value, index, arr) => {
+		acc.push(await fn(value, index, arr));
+	}, [], false);
+}
+
+/** Async version of Array.prototype.filter()
+ *	await filter(['foo', 'baz'], async v => (await fetch(v)).ok )
+ */
+export async function filter(arr, fn) {
+	return await reduce(arr, async (acc, value, index, arr) => {
+		if (await fn(value, index, arr)) acc.push(value);
+	}, [], false);
+}
+
+function identity(x) {
+	return x;
+}
+
+function resolve(list) {
+	let out = Array.isArray(list) ? [] : {};
+	for (let i in list) if (list.hasOwnProperty(i)) out[i] = list[i]();
+	return out;
+}
+
+/** Provided by standard lib, replaces async.parallel()
+ *	await parallel([
+ *		() => fetch('foo'),
+ *		() => fetch('baz')
+ *	])
+ */
+export async function parallel(list) {
+	return await Promise.all(resolve(list));
+}
+
+/** Replaces async.series()
+ *	await series([
+ *		() => fetch('foo'),
+ *		() => fetch('baz')
+ *	])
+ */
+export async function series(list) {
+	return await map(resolve(list), identity);
+}

test/index.js

@@ -0,0 +1,9 @@
+import assert from 'assert';
+import { series, parallel } from '../src';
+
+assert.equal(typeof series, 'function');
+
+assert.equal(typeof parallel, 'function');
+
+console.log('✅ success');
+process.exit(0);