From 08416246ef69661efcbf9c7abd4bd53c113d061d Mon Sep 17 00:00:00 2001 From: Tomasz Pietrek Date: Mon, 14 Oct 2024 17:08:22 +0200 Subject: [PATCH] Format code Signed-off-by: Tomasz Pietrek --- async-nats/src/jetstream/stream.rs | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/async-nats/src/jetstream/stream.rs b/async-nats/src/jetstream/stream.rs index b7230aa02..8b162d131 100755 --- a/async-nats/src/jetstream/stream.rs +++ b/async-nats/src/jetstream/stream.rs @@ -210,7 +210,7 @@ impl Stream { /// let mut info = stream.info_with_subjects("events.>").await?; /// /// while let Some((subject, count)) = info.try_next().await? { - /// println!("Subject: {} count: {}", subject, count); + /// println!("Subject: {} count: {}", subject, count); /// } /// # Ok(()) /// # } @@ -249,12 +249,15 @@ impl Stream { /// /// let mut stream = jetstream.get_stream("events").await?; /// - /// let mut info = stream.info_builder() + /// let mut info = stream + /// .info_builder() /// .with_deleted() - /// .subjects("events.>").try_next().await?; + /// .subjects("events.>") + /// .try_next() + /// .await?; /// /// while let Some((subject, count)) = info.try_next().await? { - /// println!("Subject: {} count: {}", subject, count); + /// println!("Subject: {} count: {}", subject, count); /// } /// # Ok(()) /// # }