Skip to main content

EventStream

Type Alias EventStream 

Source
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 */ }