Function async_nats::jetstream::with_prefix

source · [−]

pub fn with_prefix(client: Client, prefix: &str) -> Context

Expand description

Creates a new JetStream Context with given JetStream prefix. By default it is $JS.API.

Examples


let client = async_nats::connect("localhost:4222").await?;
let jetstream = async_nats::jetstream::with_prefix(client, "JS.acc@hub.API");

jetstream.publish("subject".to_string(), "data".into()).await?;