Trait Processor 

pub trait Processor<T>
where
    T: Sync,
{
    // Required method
    fn process(
        &mut self,
        data: &T,
    ) -> impl Future<Output = CarbonResult<()>> + Send;
}

Async handler invoked for each decoded update of type T.

Registered via PipelineBuilder (account, instruction, transaction, account_deletions, block_details). The pipeline awaits process for every update that passes filters.

Errors

Returning Err is logged and counted in metrics; processing continues. Use for recoverable failures, not pipeline termination.

Required Methods

fn process(&mut self, data: &T) -> impl Future<Output = CarbonResult<()>> + Send

Dyn Compatibility

This trait is not dyn compatible.

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

Implementors