* docs and example

Author: DevNamedZed

README.md

@@ -136,8 +136,8 @@ npx simplesteps compile workflow.ts -o output/
 | `if/else`, `switch/case` | Choice state |
 | `while`, `do...while` | Choice + back-edge loop |
 | `for (const item of array)` | Map state (parallel, with closures) |
-| `await Steps.map(items, cb, opts?)` | Map state (results, closures, MaxConcurrency) |
-| `for (const item of Steps.items(arr, opts?))` | Map state (for...of + MaxConcurrency) |
+| `await Steps.map(items, cb, opts?)` | Map state (results, closures, MaxConcurrency, Retry) |
+| `for (const item of Steps.items(arr, opts?))` | Map state (for...of + MaxConcurrency, Retry) |
 | `await Promise.all([...])` | Parallel state |
 | Deferred-await (`const p = call(); await p`) | Parallel state (auto-batched) |
 | `await Steps.delay({ seconds: 30 })` | Wait state |

docs/language-reference.md

@@ -11,8 +11,8 @@ Every TypeScript construct supported by SimpleSteps and its ASL mapping.
 | `if/else`, `switch/case` | Choice |
 | `while`, `do...while` | Choice + back-edge loop |
 | `for (const item of array)` | Map (parallel, with closures) |
-| `await Steps.map(items, callback, opts?)` | Map (with result capture, closures, MaxConcurrency) |
-| `for (const item of Steps.items(array, opts?))` | Map (for...of with MaxConcurrency + closures) |
+| `await Steps.map(items, callback, opts?)` | Map (with result capture, closures, MaxConcurrency, Retry) |
+| `for (const item of Steps.items(array, opts?))` | Map (for...of with MaxConcurrency, Retry, closures) |
 | `for (const item of Steps.sequential(array))` | Map (sequential, `MaxConcurrency: 1`) |
 | `await Promise.all([...])` | Parallel |
 | Deferred-await (`const p = call(); await p`) | Parallel (auto-batched) |

examples/aws-cdk-comparison/output/05-parallel-processing.asl.json

@@ -44,11 +44,25 @@
           }
         }
       ],
-      "ResultSelector": {
-        "profile.$": "$[0]",
-        "history.$": "$[1]",
-        "recommendations.$": "$[2]"
-      },
+      "ResultPath": "$.__parallel",
+      "Next": "Assign_profile"
+    },
+    "Assign_profile": {
+      "Type": "Pass",
+      "InputPath": "$.__parallel[0]",
+      "ResultPath": "$.profile",
+      "Next": "Assign_history"
+    },
+    "Assign_history": {
+      "Type": "Pass",
+      "InputPath": "$.__parallel[1]",
+      "ResultPath": "$.history",
+      "Next": "Assign_recommendations"
+    },
+    "Assign_recommendations": {
+      "Type": "Pass",
+      "InputPath": "$.__parallel[2]",
+      "ResultPath": "$.recommendations",
       "Next": "Return_Result"
     },
     "Return_Result": {

examples/showcase/19-parallel.ts

@@ -6,7 +6,7 @@
 //
 // Array destructuring captures each branch's output:
 //   const [a, b] = await Promise.all([callA(), callB()])
-//   → Parallel state with ResultSelector mapping $[0]→a, $[1]→b
+//   → Parallel state with ResultPath + Assign Pass states for each binding
 
 import { Steps, SimpleStepContext } from '../../packages/core/src/runtime/index';
 import { Lambda } from '../../packages/core/src/runtime/services/Lambda';

examples/showcase/32-deferred-await.ts

@@ -17,10 +17,11 @@
 //   const [a, b] = await Promise.all([call1(), call2()]);
 //
 // ASL output:
-//   Parallel (Parallel, 2 branches,
-//     ResultSelector: { order: $[0], payment: $[1] })
+//   Parallel (Parallel, 2 branches, ResultPath: $.__parallel)
 //     Branch 0: Invoke_getOrder (Task, End)
 //     Branch 1: Invoke_getPayment (Task, End)
+//   → Assign_order (Pass, InputPath: $.__parallel[0], ResultPath: $.order)
+//   → Assign_payment (Pass, InputPath: $.__parallel[1], ResultPath: $.payment)
 //   → Return_Result (Pass, End)
 
 import { Steps, SimpleStepContext } from '../../packages/core/src/runtime/index';