Fix the doc

Signed-off-by: Tomasz Pietrek <[email protected]>

async-nats/src/jetstream/stream.rs

@@ -166,16 +166,15 @@ impl Stream<Info> {
     /// ```no_run
     /// # #[tokio::main]
     /// # async fn main() -> Result<(), async_nats::Error> {
-    /// use futures::StreamExt;
+    /// use futures::TryStreamExt;
     /// let client = async_nats::connect("localhost:4222").await?;
     /// let jetstream = async_nats::jetstream::new(client);
     ///
     /// let mut stream = jetstream.get_stream("events").await?;
     ///
     /// let mut info = stream.info_with_subjects("events.>").await?;
     ///
-    /// while let Some(subject) = info.next().await {
-    ///    let (subject, count) = subject?;
+    /// while let Some((subject, count)) = info.try_next().await? {
     ///    println!("Subject: {} count: {}", subject, count);
     /// }
     /// # Ok(())