MenuPortfolioBlogSnippets

Save SnippetView Snippet

/* Sequential Promise Chain Pass the results of one func to another asynchronously Motivation: Creating data gathering, cleanup, & formatting pipelines */ var main = async (config,lib) => { var doTasks = async (config) => { let result = false; var doTask = async (task,d) => await lib[task](d); for (const task of config.tasks){ result = await doTask(task,result || config.data) } return await result; } return await doTasks(config); } var lib = { //Simple task library for demo purposes. start:async (n) => await n, //passthrough func for point of entry add:async (n) => n+= await 1, //add 1 to input mult:async (n) => n*= await 2 //return input * 2 } var config = { tasks:["start","add","mult"], //tasks to chain data: 1, //starting dataset }; var result = await main(config,lib); console.log({result})