Trait nakadion::api::api_ext::SubscriptionApiExt[−][src]

pub trait SubscriptionApiExt {
    fn reset_cursors_to_begin<T: Into<FlowId>>(
        &self, 
        id: SubscriptionId, 
        flow_id: T
    ) -> ApiFuture<'_, ()>;
}

Required methods

fn reset_cursors_to_begin<T: Into<FlowId>>(
    &self,
    id: SubscriptionId,
    flow_id: T
) -> ApiFuture<'_, ()>

Reset all the offsets for the subscription to “begin”

Implementors

impl<S> SubscriptionApiExt for S where
S: SubscriptionApi + Send + Sync + 'static,