pub type EventStream<'a> = Pin<Box<dyn Stream<Item = Result<IngestEvent, AdapterError>> + Send + 'a>>;Expand description
Boxed, Send-only stream of IngestEvents with one shared error type.
The lifetime parameter lets future adapters borrow from their config; for
self: Box<Self> impls the lifetime collapses to 'static.
Aliased Typeยง
pub struct EventStream<'a> { /* private fields */ }