const Pool = require('io-process-pool')
 
// Imagine if grep were a process that took four seconds for each line
const pool = new Pool(['grep', ['-i', '--only-matching', '"magic phrase"', '-']], { processes: 4 })
 
lotsOfLines.forEach(line => {
    pool.write(line, (error, outputLine) => {
        console.log(line, '=>', outputLine);
    })
})