run_single_ring_adapter_loop

byteor_adapters

Function run_single_ring_adapter_loop 

Source 
pub fn run_single_ring_adapter_loop<I, E>(
    single_ring: &PipelineSpecV1,
    resolver: &dyn StageResolver,
    ingress: &mut I,
    egress: &mut E,
) -> Result<AdapterLoopStats, AdapterLoopError>
where
    I: IngressAdapter,
    E: EgressAdapter,
Expand description

Run a minimal adapter loop for an in-memory SingleRing worker job.

The loop reads one message at a time from ingress, executes the provided single_ring pipeline via the in-memory executor, writes all produced outputs to egress, and flushes after each emitted message.