Struct async_nats::jetstream::context::Publish

pub struct Publish { /* private fields */ }

Used for building customized publish message.

Implementations

impl Publish

pub fn build() -> Self

Creates a new custom Publish struct to be used with.

pub fn payload(self, payload: Bytes) -> Self

Sets the payload for the message.

pub fn headers(self, headers: HeaderMap) -> Self

Adds headers to the message.

pub fn header<N: IntoHeaderName, V: IntoHeaderValue>( self, name: N, value: V, ) -> Self

A shorthand to add a single header.

pub fn message_id<T: AsRef<str>>(self, id: T) -> Self

Sets the Nats-Msg-Id header, that is used by stream deduplicate window.

pub fn expected_last_message_id<T: AsRef<str>>(self, last_message_id: T) -> Self

Sets expected last message ID. It sets the Nats-Expected-Last-Msg-Id header with provided value.

pub fn expected_last_sequence(self, last_sequence: u64) -> Self

Sets the last expected stream sequence. It sets the Nats-Expected-Last-Sequence header with provided value.

pub fn expected_last_subject_sequence(self, subject_sequence: u64) -> Self

Sets the last expected stream sequence for a subject this message will be published to. It sets the Nats-Expected-Last-Subject-Sequence header with provided value.

pub fn expected_stream<T: AsRef<str>>(self, stream: T) -> Self

Sets the expected stream name. It sets the Nats-Expected-Stream header with provided value.

Trait Implementations

impl Clone for Publish

fn clone(&self) -> Publish

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Publish

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

Formats the value using the given formatter.

impl Default for Publish

fn default() -> Publish

Returns the “default value” for a type.