use crate::runners::EventStream;
use async_trait::async_trait;
pub type AnalyzerError = Box<dyn std::error::Error + Send + Sync>;
#[async_trait]
pub trait Analyzer: Send + Sync {
async fn process(&mut self, stream: EventStream) -> Result<EventStream, AnalyzerError>;
}