1 2 3 4 5 6 7 8
use crate::UserEvent; use crate::error::Result; use async_trait::async_trait; #[async_trait] pub trait DataSink: Send + Sync { async fn write(&mut self, events: &[UserEvent]) -> Result<()>; }