Make examples up to date

async-nats/examples/concurrent.rs

@@ -35,6 +35,9 @@ async fn main() -> Result<(), async_nats::Error> {
             .await?;
     }
 
+    // Flush the internal buffer and ensure that all messages are sent.
+    client.flush().await?;
+
     // Iterate over messages concurrently.
     // for_each_concurrent allows us to not wait for time-consuming operation and receive next
     // message immediately.

async-nats/examples/jetstream_pull.rs

@@ -37,6 +37,11 @@ async fn main() -> Result<(), async_nats::Error> {
     for i in 0..10 {
         jetstream
             .publish(format!("events.{i}"), "data".into())
+            // The first `await` sends the publish
+            .await?
+            // The second `await` awaits a publish acknowledgement.
+            // This can be skipped (for the cost of processing guarantee)
+            // or deferred to not block another `publish`
             .await?;
     }
 

async-nats/examples/pub.rs

@@ -21,10 +21,10 @@ async fn main() -> Result<(), async_nats::Error> {
     let now = Instant::now();
     let subject = String::from("foo");
     let dat = Bytes::from("bar");
-    client.flush().await?;
     for _ in 0..10_000_000 {
         client.publish(subject.clone(), dat.clone()).await?;
     }
+    client.flush().await?;
 
     println!("published in {:?}", now.elapsed());