Streaming API
=============

Public authoring API
--------------------

.. autosummary::
   :toctree: generated

   loom.streaming
   loom.streaming.compiler

Runtime adapter
---------------

.. autosummary::
   :toctree: generated

   loom.streaming.bytewax
   loom.streaming.bytewax.runner

Transport and observability
---------------------------

.. autosummary::
   :toctree: generated

   loom.streaming.kafka
   loom.streaming.testing