fn render_shutdown_fuse<G, D>(
collection: Collection<G, D, Diff>,
probe: ShutdownProbe,
) -> Collection<G, D, Diff>
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.