mz_compute::render

Function render_shutdown_fuse

Source 
fn render_shutdown_fuse<G, D>(
    collection: Collection<G, D, Diff>,
    probe: ShutdownProbe,
) -> Collection<G, D, Diff>
where
    G: Scope,
    D: Data,
Expand description

Wraps the provided Collection with an operator that passes through all received inputs as long as the provided ShutdownProbe does not announce dataflow shutdown. Once the token dataflow is shutting down, all data flowing into the operator is dropped.