Skip to content

Commit c8fe850

Browse files
committed
Update code according to new rustfmt rules (run cargo fmt)
1 parent 8f91a9c commit c8fe850

File tree

1 file changed

+14
-3
lines changed

1 file changed

+14
-3
lines changed

src/reader/async_tokio.rs

+14-3
Original file line numberDiff line numberDiff line change
@@ -119,7 +119,8 @@ impl<R: AsyncBufRead + Unpin> Reader<R> {
119119
mut buf: &'b mut Vec<u8>,
120120
) -> Result<Event<'b>> {
121121
read_event_impl!(
122-
self, buf,
122+
self,
123+
buf,
123124
TokioAdapter(&mut self.reader),
124125
read_until_close_async,
125126
await
@@ -181,7 +182,16 @@ impl<R: AsyncBufRead + Unpin> Reader<R> {
181182
end: QName<'n>,
182183
buf: &mut Vec<u8>,
183184
) -> Result<Span> {
184-
Ok(read_to_end!(self, end, buf, read_event_into_async, { buf.clear(); }, await))
185+
Ok(read_to_end!(
186+
self,
187+
end,
188+
buf,
189+
read_event_into_async,
190+
{
191+
buf.clear();
192+
},
193+
await
194+
))
185195
}
186196

187197
/// Private function to read until `>` is found. This function expects that
@@ -410,7 +420,8 @@ mod test {
410420
read_until_close_async,
411421
TokioAdapter,
412422
&mut Vec::new(),
413-
async, await
423+
async,
424+
await
414425
);
415426

416427
#[test]

0 commit comments

Comments
 (0)