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