Crate jetstream_extra 

JetStream extensions for async-nats.

This crate provides additional functionality for NATS JetStream that extends the capabilities of the async-nats client.

Features

Batch Publishing

The batch_publish module provides atomic batch publishing capabilities:

// Publish multiple messages as an atomic batch
let mut batch = client.batch_publish().build();
batch.add("events.1", "data1".into()).await?;
batch.add("events.2", "data2".into()).await?;
let ack = batch.commit("events.3", "final".into()).await?;

See the batch_publish module for detailed documentation.

Modules

batch_publish

Batch publishing support for NATS JetStream.