Skip to main content

pump_interpreter_to_distributor

monoloop_testkit

Function pump_interpreter_to_distributor 

Source 
pub async fn pump_interpreter_to_distributor(
    events: Arc<CanonicalEventStream>,
    distributor: EventDistributor,
)
Expand description

Bridge: drain an interpreter event stream into a distributor, then close.