SubscriptionStream

Type Alias SubscriptionStream 

Source
pub type SubscriptionStream<'a, S> = Pin<Box<dyn Stream<Item = Result<Persisted<<S as Subscription>::SourceId, <S as Subscription>::Event>, <S as Subscription>::Error>> + Send + 'a>>;
Expand description

Stream of events returned by the Subscription::resume method.

Aliased Typeยง

pub struct SubscriptionStream<'a, S> { /* private fields */ }