Struct IncomingSubscription 

pub struct IncomingSubscription<E> {
    pub events: BoxDynStream<'static, Result<IncomingEvent, E>>,
    /* private fields */
}

The receipt callback accepts only positions committed to local storage.

Fields

events: BoxDynStream<'static, Result<IncomingEvent, E>>

Ordered transport events. Reading an event does not commit receipt.

Implementations

impl<E> IncomingSubscription<E>

pub fn new( events: BoxDynStream<'static, Result<IncomingEvent, E>>, receipt: impl Fn(TopicCursor) + MaybeSend + MaybeSync + 'static, ) -> Self

Attach a receipt callback to an owned event stream.

pub fn acknowledge_received(&self, cursors: TopicCursor)

Advance resume positions only to the committed received prefix F. Do not acknowledge positions that exist only in memory.

pub fn map_error<U, F>(self, map: F) -> IncomingSubscription<U>

where E: 'static, U: 'static, F: Fn(E) -> U + MaybeSend + 'static,

Convert transport errors without changing the receipt callback.