Struct async_nats::jetstream::stream::Purge

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

Implementations

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

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

Adds subject filter to PurgeRequest

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

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

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

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

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

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

Trait Implementations

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

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

Formats the value using the given formatter.

impl<S, K> IntoFuture for Purge<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 + 'static, Global>>

Which kind of future are we turning this into?

fn into_future(self) -> Self::IntoFuture

Creates a future from a value.