result-aggregationlisted
Install: claude install-skill othmane55/claude-collective-intelligence
# Result Aggregation
Collect, combine, and synthesize results from distributed agent execution.
## Quick Start
### Basic Result Collection
```javascript
const results = [];
await client.consumeResults('agent.results', async (msg) => {
results.push(msg.result);
console.log(`Received result ${results.length}`);
});
```
### Wait for All Results
```javascript
async function collectAllResults(taskIds) {
const results = new Map();
return new Promise((resolve) => {
client.consumeResults('agent.results', async (msg) => {
const { taskId, result } = msg.result;
results.set(taskId, result);
// Check if all results received
if (results.size === taskIds.length) {
resolve(Array.from(results.values()));
}
});
});
}
```
## Aggregation Patterns
### Pattern 1: Collect and Merge
Combine all results into single output.
```javascript
async function collectAndMerge(taskCount) {
const results = [];
await consumeResults('agent.results', async (msg) => {
results.push(msg.result);
if (results.length === taskCount) {
// All results received, merge them
const merged = mergeResults(results);
console.log('Final result:', merged);
}
});
}
function mergeResults(results) {
// Example: Merge test results
return {
totalTests: sum(results.map(r => r.tests)),
passed: sum(results.map(r => r.passed)),
failed: sum(results.map(r => r.failed)),
duration: max(results.map(r => r.duration)),