nominal_streaming/
notifier.rs

1use std::error::Error;
2use std::fmt::Debug;
3
4use tracing::error;
5
6pub trait NominalStreamListener: Send + Sync + Debug {
7    fn on_error(&self, message: &str, error: &dyn Error);
8}
9
10#[derive(Debug, Default, Clone)]
11pub struct LoggingListener;
12
13impl NominalStreamListener for LoggingListener {
14    fn on_error(&self, message: &str, error: &dyn Error) {
15        error!("{}: {}", message, error);
16    }
17}