Struct JetStreamPublish 

pub struct JetStreamPublish { /* private fields */ }

The JetStream publish policy: pure declaration, constructible anywhere.

Beyond naming the transport, the policy carries the stream expectations the server checks before accepting a message. They are per-publisher declarations: a publisher that states expect_stream("ORDERS") fails loudly if its subject is routed to another stream, instead of writing somewhere unintended. The sequence and message-id expectations serve a single writer enforcing an optimistic-concurrency chain.

Examples

use ruststream_nats::JetStreamPublish;

let policy = JetStreamPublish::default().expect_stream("ORDERS");

Implementations

impl JetStreamPublish

pub fn expect_stream(self, stream: impl Into<String>) -> Self

Requires the subject to be served by the named stream. The server rejects the publish otherwise, so a misrouted subject surfaces as an error rather than a silent write.

pub const fn expect_last_sequence(self, sequence: u64) -> Self

Requires the stream’s last sequence to be sequence at the moment of the publish.

pub const fn expect_last_subject_sequence(self, sequence: u64) -> Self

Requires the last sequence on the published subject to be sequence.

pub fn expect_last_message_id(self, id: impl Into<String>) -> Self

Requires the stream’s last message id (the Nats-Msg-Id of the previous publish) to be id.

Trait Implementations

impl Clone for JetStreamPublish

fn clone(&self) -> JetStreamPublish

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for JetStreamPublish

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

Formats the value using the given formatter.

impl Default for JetStreamPublish

fn default() -> JetStreamPublish

Returns the “default value” for a type.

impl Eq for JetStreamPublish

impl NatsPublishPolicy for JetStreamPublish

fn bind(self, connected: &ConnectedNatsBroker) -> Self::Live

Pairs the policy with the connected broker, producing the live publisher.

impl PartialEq for JetStreamPublish

fn eq(&self, other: &JetStreamPublish) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl PublishPolicy<ConnectedNatsBroker> for JetStreamPublish

type Live = JetStreamPublisher

The live form this policy pairs into: a Publisher for a leaf policy, or the live wiring form for a combinator stack (a typed publisher over a policy pairs into the same typed publisher over the live leaf).

async fn pair( self, connected: &ConnectedNatsBroker, ) -> Result<Self::Live, PairError>

Pairs the policy with a connected broker, producing the live publisher.

impl StructuralPartialEq for JetStreamPublish