diff --git a/async-nats/src/jetstream/consumer/pull.rs b/async-nats/src/jetstream/consumer/pull.rs index 098b74454..fb7869f9a 100644 --- a/async-nats/src/jetstream/consumer/pull.rs +++ b/async-nats/src/jetstream/consumer/pull.rs @@ -531,7 +531,6 @@ impl<'a> Consumer { /// let mut messages = consumer.messages().await?.take(100); /// while let Some(Ok(message)) = messages.next().await { /// println!("got message {:?}", message); - /// message.ack().await?; /// } /// Ok(()) /// # }