Add client.flush() calls to example code in docs

nats-io · May 20, 2024 · 0088b85 · 0088b85
1 parent 66e8f99
commit 0088b85
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/async-nats/src/lib.rs b/async-nats/src/lib.rs
@@ -84,6 +84,10 @@
 //! for _ in 0..10 {
 //!     client.publish(subject, data.clone()).await?;
 //! }
+//!
+//! // Flush internal buffer before exiting to make sure all messages are sent
+//! client.flush().await?;
+//!
 //! #    Ok(())
 //! # }
 //! ```