Skip to content

Commit

Permalink
Format code
Browse files Browse the repository at this point in the history
Signed-off-by: Tomasz Pietrek <[email protected]>
  • Loading branch information
Jarema committed Oct 14, 2024
1 parent 36cb05a commit 0841624
Showing 1 changed file with 7 additions and 4 deletions.
11 changes: 7 additions & 4 deletions async-nats/src/jetstream/stream.rs
Original file line number Diff line number Diff line change
Expand Up @@ -210,7 +210,7 @@ impl<I> Stream<I> {
/// 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(())
/// # }
Expand Down Expand Up @@ -249,12 +249,15 @@ impl<I> Stream<I> {
///
/// 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(())
/// # }
Expand Down

0 comments on commit 0841624

Please sign in to comment.