Streaming API

Public authoring API

loom.streaming	Loom Streaming — topic-oriented declarations and transport adapters.
loom.streaming.compiler	Streaming compiler: validates StreamFlow and produces CompiledPlan.

Runtime adapter

loom.streaming.bytewax	Bytewax runtime adapter for Loom streaming flows.
loom.streaming.bytewax.runner	StreamingRunner — production Bytewax runtime entry point for Loom flows.

Transport and observability

loom.streaming.kafka	Kafka transport contracts for Loom streaming.
loom.streaming.testing	Streaming testing helpers built on top of Bytewax testing sinks and sources.