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.