stream_processor_test

Trait OutputValidator

Source
pub trait OutputValidator {
    // Required method
    fn validate<'life0, 'life1, 'async_trait>(
        &'life0 self,
        output: &'life1 [Output],
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
}
Expand description

Checks all output packets, which are provided to the validator in the order in which they were received from the stream processor.

Failure should be indicated by returning an error, not by panic, so that the full context of the error will be available in the failure output.

Required Methods§

Source

fn validate<'life0, 'life1, 'async_trait>( &'life0 self, output: &'life1 [Output], ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Implementors§