Revert "feat: simplify the fan-in/fan-out logic (#64)" (#76)

This reverts commit 5947de2.

Author: logan-markewich

examples/document_processing.ipynb

@@ -434,7 +434,7 @@
   },
   {
    "cell_type": "code",
-   "execution_count": null,
+   "execution_count": 15,
    "metadata": {},
    "outputs": [
     {
@@ -577,11 +577,9 @@
     "        approved = input(\"Approve? (y/<reason>): \").strip().lower()\n",
     "        print(f\"Approved? {approved}\", flush=True)\n",
     "        if approved == \"y\":\n",
-    "            handler.ctx.send_events(\n",
-    "                [ApprovedSchema(approved=True, feedback=\"Approved\")]\n",
-    "            )\n",
+    "            handler.ctx.send_event(ApprovedSchema(approved=True, feedback=\"Approved\"))\n",
     "        else:\n",
-    "            handler.ctx.send_events([ApprovedSchema(approved=False, feedback=approved)])\n",
+    "            handler.ctx.send_event(ApprovedSchema(approved=False, feedback=approved))\n",
     "\n",
     "result = await handler\n",
     "print(f\"Agent ID: {result.agent_id}\", flush=True)\n",
@@ -601,7 +599,7 @@
   },
   {
    "cell_type": "code",
-   "execution_count": null,
+   "execution_count": 16,
    "metadata": {},
    "outputs": [],
    "source": [
@@ -623,7 +621,7 @@
     "    if existing_context:\n",
     "        ctx = Context.from_dict(wf, existing_context)\n",
     "        handler = wf.run(ctx=ctx)\n",
-    "        handler.ctx.send_events([response_ev])\n",
+    "        handler.ctx.send_event(response_ev)\n",
     "    else:\n",
     "        handler = wf.run(file_path=file_path, prompt=prompt)\n",
     "\n",