[−][src]Trait nakadion::api::api_ext::SubscriptionApiExt
Required methods
fn reset_cursors_to_begin<T: Into<FlowId>>(
&self,
id: SubscriptionId,
flow_id: T
) -> ApiFuture<()>
&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,
[src]
S: SubscriptionApi + Send + Sync + 'static,
fn reset_cursors_to_begin<T: Into<FlowId>>(
&self,
id: SubscriptionId,
flow_id: T
) -> ApiFuture<()>
[src]
&self,
id: SubscriptionId,
flow_id: T
) -> ApiFuture<()>
Resets all cursors of the given subscription to CursorOffset::Begin