Module streaming_coordinator 

Single-task pipeline coordinator on the dedicated laminar-compute thread.

Source task (main runtime) ──MAsyncTx──► StreamingCoordinator
                                              │  execute_cycle / write_to_sinks
                                              ▼  Sinks

Structs

StreamingCoordinator

Single-task pipeline coordinator — no core threads.

StreamingCoordinatorRuntime

Stable owner for source generations constructed through StreamingCoordinator::new.

Enums

ExitReason

Why StreamingCoordinator::run returned.