Struct async_nats::jetstream::stream::Purge

pub struct Purge<'a, SEQUENCE, KEEP>where
    SEQUENCE: ToAssign,
    KEEP: ToAssign,{ /* private fields */ }

Implementations

impl<'a, SEQUENCE, KEEP> Purge<'a, SEQUENCE, KEEP>where SEQUENCE: ToAssign, KEEP: ToAssign,

pub fn filter<T: Into<String>>(self, filter: T) -> Purge<'a, SEQUENCE, KEEP>

Adds subject filter to PurgeRequest

impl<'a, KEEP> Purge<'a, No, KEEP>where KEEP: ToAssign,

pub fn keep(self, keep: u64) -> Purge<'a, No, Yes>

Creates a new PurgeRequest. keep and sequence are exclusive, enforced compile time by generics.

impl<'a, SEQUENCE> Purge<'a, SEQUENCE, No>where SEQUENCE: ToAssign,

pub fn sequence(self, sequence: u64) -> Purge<'a, Yes, No>

Creates a new PurgeRequest. keep and sequence are exclusive, enforces compile time by generics.

Trait Implementations

impl<'a, SEQUENCE, KEEP> Debug for Purge<'a, SEQUENCE, KEEP>where SEQUENCE: ToAssign + Debug, KEEP: ToAssign + Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'a, S, K> IntoFuture for Purge<'a, S, K>where S: ToAssign + Send, K: ToAssign + Send,

type Output = Result<PurgeResponse, Box<dyn Error + Send + Sync + 'static, Global>>

The output that the future will produce on completion.

type IntoFuture = Pin<Box<dyn Future<Output = Result<PurgeResponse, Box<dyn Error + Send + Sync + 'static, Global>>> + Send + 'a, Global>>

Which kind of future are we turning this into?

fn into_future(self) -> Self::IntoFuture

Creates a future from a value.