Skip to main content

SinkDrainFn

Type Alias SinkDrainFn 

Source
pub type SinkDrainFn = Box<dyn FnOnce(Duration) -> Pin<Box<dyn Future<Output = DrainReport> + Send>> + Send>;
Expand description

Boxed sink drain hook: budget in, report out. Produced by sink assemblies (wrapping SinkPool::drain), consumed once at shutdown by the pipeline runtime.

Aliased Typeยง

pub struct SinkDrainFn(/* private fields */);