Add Pull Consumer builders

nats-io · Jul 12, 2022 · 3106cd1 · 3106cd1
1 parent 5d261c3
commit 3106cd1
Show file tree

Hide file tree

Showing 5 changed files with 527 additions and 72 deletions.
diff --git a/async-nats/examples/jetstream_pull.rs b/async-nats/examples/jetstream_pull.rs
@@ -23,7 +23,7 @@ async fn main() -> Result<(), async_nats::Error> {
             .await?;
     }
 
-    let mut messages = consumer.stream().await?.take(10);
+    let mut messages = consumer.messages().await?.take(10);
 
     while let Some(message) = messages.next().await {
         let message = message?;