Switch from fetch to batch in test

Signed-off-by: Tomasz Pietrek <[email protected]>
nats-io · May 23, 2024 · 0942c47 · 0942c47
1 parent ec6331c
commit 0942c47
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/async-nats/tests/jetstream_tests.rs b/async-nats/tests/jetstream_tests.rs
@@ -2375,7 +2375,7 @@ mod jetstream {
                 .unwrap();
         }
 
-        let mut iter = consumer.fetch().max_messages(100).messages().await.unwrap();
+        let mut iter = consumer.batch().max_messages(10).messages().await.unwrap();
         client.flush().await.unwrap();
 
         tryhard::retry_fn(|| async {