Trait ObservationSink 

pub trait ObservationSink: Send {
    // Required method
    fn on_observation(&mut self, observation: &Observation) -> ControlFlow;

    // Provided method
    fn on_complete(&mut self) { ... }
}

A callback that receives observations during execution.

Implement this trait to process observations in real-time. The default implementation collects into a Vec (batch mode).

Required Methods

fn on_observation(&mut self, observation: &Observation) -> ControlFlow

Called for each observation during execution.

Return ControlFlow::Continue to keep executing. Return ControlFlow::Halt to stop immediately.

Provided Methods

fn on_complete(&mut self)

Called when execution completes (normally or via halt). Override to perform cleanup or final analysis.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl ObservationSink for BatchCollector

impl ObservationSink for CountingSink

impl<F: FnMut(&Observation) -> bool + Send> ObservationSink for EarlyStopSink<F>