🔗 Stream-Chain

/cloud--deployment/stream-chain

Stream-Chain enables sequential processing where the output of one agent becomes the input of the next.

Pipeline Concept

┌─────────────────────────────────────────────────────────────────────┐
│                     STREAM-CHAIN PIPELINE                           │
├─────────────────────────────────────────────────────────────────────┤
│                                                                     │
│  Input ──▶ [Agent 1] ──▶ [Agent 2] ──▶ [Agent 3] ──▶ Output        │
│            (Research)    (Implement)   (Test)                       │
│                                                                     │
│  Each stage transforms and passes data to the next                  │
│                                                                     │
└─────────────────────────────────────────────────────────────────────┘

Creating Pipelines

bash

/stream-chain

npx ruflo@latest stream-chain create \
  --name "feature-pipeline" \
  --stages "researcher,architect,coder,tester,reviewer"

Pipeline Definition (YAML)

yaml

name: feature-development
description: End-to-end feature implementation

stages:
  - name: research
    agent: researcher
    input: requirements
    output: analysis

  - name: design
    agent: architect
    input: analysis
    output: architecture

  - name: implement
    agent: coder
    input: architecture
    output: code

  - name: test
    agent: tester
    input: code
    output: test_results

  - name: review
    agent: reviewer
    input: [code, test_results]
    output: final_review

Running Pipelines

bash

npx ruflo@latest stream-chain run feature-pipeline \
  --input '{"requirements": "Add user dashboard with analytics"}'

npx ruflo@latest stream-chain status feature-pipeline

Use Cases

Pipeline	Stages	Output
Feature Development	research → design → implement → test → review	Reviewed code
Security Audit	scan → analyze → remediate → verify	Security report
Documentation	research → outline → write → review	Documentation
Migration	analyze → plan → migrate → validate	Migrated code

☁️ Flow Nexus

👥 Pair Programming