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

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"

Loading content...

Implementors

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

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

Resets all cursors of the given subscription to CursorOffset::Begin

Loading content...