pub type EventStream<E> = UnboundedReceiver<ScheduledEvent<E>>;
pub struct EventStream<E> { /* private fields */ }