got parallel limit example.js

const got = require('got');
const { parallelLimit } = require('async');

const body = { feature: 'my_feature', other: 'yes' };

const bodies = [
	{ feature: 'my_feature', other: 'yes' },
	{ feature: 'my_feature3', other: 'yes' },
	{ feature: 'my_feature2', other: 'yes2' }
];

const queue = bodies.map(body => {
	return cb => {
		got
			.post('http://localhost:3000/test', {
				json: true,
				body
			})
			.then(res => cb(null, { feature: body.feature, err: null, res: res.body || 'success' }))
			.catch(err => {
				cb(null, { feature: body.feature, err: err.response.body.error });
			});
	};
});

parallelLimit(queue, 50, (err, results) => {
	console.log(JSON.stringify(err, null, 2));
	console.log(JSON.stringify(results, null, 2));
});