Skip to content

Commit 53679c6

Browse files
committed
Forums pt 3
1 parent a015315 commit 53679c6

3 files changed

Lines changed: 9 additions & 4 deletions

File tree

README.md

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -798,14 +798,19 @@ val pipeline = (quick / deep) then synthesizer
798798

799799
### `*` — Forum (Multi-Agent Discussion)
800800

801-
Think *jury deliberation* — the case lands on the table, agents discuss across rounds, the last agent (foreperson) delivers the verdict. Agents see each other's reasoning; parallel agents do not.
801+
Think *jury deliberation* — the case lands on the table, agents discuss across rounds, the last agent (foreperson) delivers the verdict. Agents see each other's reasoning; parallel agents do not. All participants run concurrently; the captain delivers the final result.
802802

803803
```kotlin
804804
val forum = initiator * analyst * critic * captain
805805
// Forum<Specs, Decision>
806806

807807
val pipeline = inputConverter then forum then formatter
808808
// Pipeline<Input, FormattedDecision>
809+
810+
// Track the debate as it unfolds
811+
forum.onMentionEmitted { agentName, output ->
812+
println("[$agentName]: $output")
813+
}
809814
```
810815

811816
### `.loop {}` — Iterative Execution
@@ -922,7 +927,7 @@ cd Agents.KT
922927
- [x] `Skill.knowledgeTools()` / `KnowledgeTool(name, description, call)` — tools model with lazy per-entry loading
923928
- [x] `then` — sequential pipeline with composed execution (no runtime casts)
924929
- [x] `/` — parallel fan-out with coroutine concurrency
925-
- [x] `*` — forum (multi-agent discussion)
930+
- [x] `*` — forum (multi-agent discussion) with concurrent participants, captain, and `onMentionEmitted` debate tracking
926931
- [x] Single-placement enforcement across all structure types
927932
- [x] `.loop {}` — iterative execution with `(OUT) -> IN?` feedback block
928933
- [x] `.branch {}` — conditional routing on sealed types, composable with `then`

build.gradle.kts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@ plugins {
55
}
66

77
group = "ai.deep-code"
8-
version = "0.1.1"
8+
version = "0.1.2"
99

1010
repositories {
1111
mavenCentral()

docs/prd.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3782,7 +3782,7 @@ Bidirectional: draw UML → generate DSL, write DSL → visualize as UML.
37823782
- ~~Skill routing: predefined rules + `RoutingStrategy.LLM_DECISION`~~ ✓ done
37833783
- MCP server: expose agents as MCP endpoints (§5.8)
37843784
- Pipeline observability: `observe {}`, `Flow<PipelineEvent>` (§10.2)
3785-
- Forum discussion rounds and ~~Parallel coroutine execution~~ ✓ done
3785+
- ~~Forum discussion rounds and Parallel coroutine execution~~ ✓ done — Forum.invoke() with concurrent participants + captain, `onMentionEmitted` debate tracking
37863786

37873787
### Phase 3: Production (Q3 2026)
37883788

0 commit comments

Comments
 (0)