pub type EventStream<R> = RecordStream<Event, R>;