aion-rs 0.5.0

Transport-agnostic Aion workflow engine with durability, replay, timers, and supervision.
1
2
3
4
5
6
7
8
9
10

//! Live event publication: publish-after-commit store wrapper and the
//! broadcast-backed [`crate::EventPublisher`] implementation.

/// Broadcast-backed event publisher seam implementation.
pub mod publisher;
/// Publish-after-commit event-store wrapper.
pub mod store;

pub use publisher::BroadcastEventPublisher;
pub use store::{PublishError, PublishingEventStore};