pub trait StatementHandler: Send + Sync { // Required method fn on_statement( &self, statement: &Statement, raw: &[u8], ) -> Result<(), String>; }
Receives decoded statements after dedup.
Called for each unique statement that passes the dedup filter.
Return Err to signal a handler-level problem; other handlers are still called and the error is logged at warn level.
Err
warn