Skip to content

Commit

Permalink
Update code according to new rustfmt rules (run cargo fmt)
Browse files Browse the repository at this point in the history
  • Loading branch information
Mingun committed Mar 8, 2025
1 parent 8f91a9c commit c8fe850
Showing 1 changed file with 14 additions and 3 deletions.
17 changes: 14 additions & 3 deletions src/reader/async_tokio.rs
Original file line number Diff line number Diff line change
Expand Up @@ -119,7 +119,8 @@ impl<R: AsyncBufRead + Unpin> Reader<R> {
mut buf: &'b mut Vec<u8>,
) -> Result<Event<'b>> {
read_event_impl!(
self, buf,
self,
buf,
TokioAdapter(&mut self.reader),
read_until_close_async,
await
Expand Down Expand Up @@ -181,7 +182,16 @@ impl<R: AsyncBufRead + Unpin> Reader<R> {
end: QName<'n>,
buf: &mut Vec<u8>,
) -> Result<Span> {
Ok(read_to_end!(self, end, buf, read_event_into_async, { buf.clear(); }, await))
Ok(read_to_end!(
self,
end,
buf,
read_event_into_async,
{
buf.clear();
},
await
))
}

/// Private function to read until `>` is found. This function expects that
Expand Down Expand Up @@ -410,7 +420,8 @@ mod test {
read_until_close_async,
TokioAdapter,
&mut Vec::new(),
async, await
async,
await
);

#[test]
Expand Down

0 comments on commit c8fe850

Please sign in to comment.