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, Error<PurgeErrorKind>>

The output that the future will produce on completion.

type IntoFuture = Pin<Box<dyn Future<Output = Result<PurgeResponse, Error<PurgeErrorKind>>> + Send>>

Which kind of future are we turning this into?

fn into_future(self) -> Self::IntoFuture

Creates a future from a value.