The Developer Platform Built for True Code Mastery.

// Async pipeline with Promise.all
async function processDataStream(items) {
  console.log("Processing", items.length, "items...");

  const results = await Promise.all(
    items.map(async (n) => {
      const transformed = Math.pow(n, 2) + 1;
      return { input: n, output: transformed, status: "OK" };
    })
  );
  
  return results.filter(r => r.output > 10);
}

const batch = [2, 3, 5, 8];
processDataStream(batch).then(data => {
  console.log("Records with output > 10:", data.length);
  console.log("First match:", JSON.stringify(data[0]));
});