import limitor from 'limitor'
import { of, parallel } from 'fluture'
 
/**
 * This example demonstrates how to group an array
 * of futures and ensure only the limit is executed
 * every second.
 * 
 * Below, the first 2 futures will resolve instantly
 * and 1 second later the next 2 will resolve.
 */
 
const futures = [of(1), of(1), of(2), of(2)]
const limit = 2 // max 2 per second
 
const limited = limitor (futures) (limit)
 
parallel(Infinity, limited).fork(console.error, console.log)