Module pipeline 

Async stream pipeline types.

The full pipeline: Source → TextStream → SpanStream → AttributeStream → DiagnosticStream → Sink

Each stage is a Stream. Middleware inserts between stages. This module defines the stage types; full async streaming implementation is TODO.

Structs

TextChunk

A chunk of source text with its byte offset in the original document.

Enums

SourceError

Error type for stream sources.

Traits

Sink

A stream sink — anything that consumes pipeline output.

Source

A stream source — anything that produces TextChunks. Implemented by: string buffer (WASM/server), file reader (CLI/batch), HTTP body.