1 2 3 4 5 6 7 8
use async_trait::async_trait; use crate::events::{Error, Event}; #[async_trait] pub trait Publisher { async fn publish(&self, events: &[Event]) -> Result<(), Error>; }