Trait JetStreamPublishSteps

Source

pub trait JetStreamPublishSteps {
    // Required methods
    fn message_id(self, id: impl Into<String>) -> Self;
    fn expect_last_sequence(self, sequence: u64) -> Self;
    fn expect_last_subject_sequence(self, sequence: u64) -> Self;
    fn expect_last_message_id(self, id: impl Into<String>) -> Self;
}

Expand description

The per-message JetStream settings, as steps on the publish builder.

A handler body that adjusts one of these names this crate’s prelude and bounds its slot Out<impl Publisher<Options = JetStreamOptions>, Marker>. That body is tied to JetStream, and its signature says so; a body that publishes plainly stays on the framework prelude alone.

The steps sit on the builder rather than on a publisher of their own, so the publish they finish still travels through the mount site’s entry, with the codec and the transforms that entry named.

§Examples

use ruststream_nats::prelude::*;
#[derive(Serialize, Outgoing)]
struct Archived {
    id: u64,
}

ledger
    .message(archived)
    .to("orders.archived")
    .message_id(format!("order-{}", archived.id))
    .expect_last_subject_sequence(41)
    .publish()
    .await?;