v4.1.0 — Streaming Adapters, A2A Protocol, Real LangChain Example

[Jovancoding]

v4.1.0 — Streaming Adapters, A2A Protocol, Real LangChain Example

## What's New

### 🔴 Streaming Adapters
Incremental token streaming is now a first-class adapter primitive.

- **`StreamingBaseAdapter`** — abstract base class with `executeAgentStream()` returning `AsyncIterable<StreamingChunk>`. Default single-chunk fallback wraps any existing `executeAgent()` result, so no existing adapter breaks.
- **`LangChainStreamingAdapter`** — drop-in replacement for `LangChainAdapter`. Automatically detects Runnables that expose `.stream()` (LCEL chains, `ChatOpenAI`, etc.) and yields tokens incrementally. Falls back to `.invoke()` for non-streamable runnables.
- **`CustomStreamingAdapter`** — drop-in replacement for `CustomAdapter`. Handlers can now be async generator functions that `yield` tokens. Plain `Promise`-returning handlers continue to work unchanged.
- **`collectStream()` helper** — drain any stream into `{ output: string, chunks: StreamingChunk[] }` in one call.
- **`types/streaming-adapter.d.ts`** — `StreamingChunk`, `IStreamingAdapter`, `StreamCollector` types.

```typescript
for await (const chunk of adapter.executeAgentStream('analyst', payload, ctx)) {
  process.stdout.write(chunk.text);
  if (chunk.done) break;
}

🤝 A2A Protocol Adapter

Full implementation of the Google A2A open protocol — the emerging standard for agent interoperability.

• Fetches remote Agent Cards from /.well-known/agent.json
• Sends JSON-RPC 2.0 tasks/send envelopes to the agent's task endpoint
• Bearer token auth, configurable timeout, AbortController hang guard
• registerRemoteAgent(id, baseUrl) — auto-discovers capability from the card
• registerLocalA2AAgent(id, card) — register without a network fetch (e.g. from config)

const adapter = new A2AAdapter();
await adapter.initialize({});
await adapter.registerRemoteAgent('remote-analyst', 'https://agent.example.com');
// then use in any orchestrator: delegate_task → a2a:remote-analyst

🔗 Real LangChain Example (09-real-langchain.ts)

End-to-end walkthrough wiring actual LangChain Runnables into the orchestrator — no mocks in production code. Swap the mockRunnable() stubs for ChatOpenAI + RunnableSequence and it runs against a real LLM. Shows:

• LangChain analysis chain → summary chain pipeline
• CustomAdapter running in parallel in the same swarm (cross-framework)
• AuthGuardian permission gate + blackboard persistence

---

Tests

1,283 passing across 15 suites — 67 new assertions, 0 failures.

New suite	Assertions	Covers
test-streaming.ts	31	Fallback wrapper, collectStream, generator handlers, AIMessage chunks, error paths
test-a2a.ts	34	Init, local/remote register, happy-path execute, HTTP/A2A/state errors, multi-artifact, mock fetch

---

Breaking Changes

None. All additions are additive — no existing exports, types, or behaviours were modified.

---

Upgrade

npm install network-ai@4.1.0
# or
clawhub update network-ai

https://github.com/jovanSAPFIONEER/Network-AI/blob/main/CHANGELOG.md#4100---2026-03-05

---

This discussion was created from the release v4.1.0 — Streaming Adapters, A2A Protocol, Real LangChain Example.