pub fn with_domain<T: AsRef<str>>(client: Client, domain: T) -> Context
Creates a new JetStream Context with given JetStream domain.
let client = async_nats::connect("localhost:4222").await?; let jetstream = async_nats::jetstream::with_domain(client, "hub"); jetstream.publish("subject", "data".into()).await?;