Type Alias SupervisionDecider 

pub type SupervisionDecider = Arc<dyn Fn(&StreamError) -> SupervisionDirective + Send + Sync>;

Shared supervision decider used by supervised operators.

The decider is user code and is always invoked outside Datum’s internal locks. If it panics, the supervised stage treats that as SupervisionDirective::Stop.

Aliased Type

pub struct SupervisionDecider { /* private fields */ }