run cargo fmt

tokio/src/io/util/copy_bidirectional.rs

@@ -77,23 +77,45 @@ where
  A: AsyncRead + AsyncWrite + Unpin + ?Sized,
  B: AsyncRead + AsyncWrite + Unpin + ?Sized,
 {
- copy_bidirectional_impl(a, b, CopyBuffer::new(super::DEFAULT_BUF_SIZE), CopyBuffer::new(super::DEFAULT_BUF_SIZE)).await
+ copy_bidirectional_impl(
+ a,
+ b,
+ CopyBuffer::new(super::DEFAULT_BUF_SIZE),
+ CopyBuffer::new(super::DEFAULT_BUF_SIZE),
+ )
+ .await
 }
 
 /// The same as the [`copy_bidirectional()`], but allows to set the underlying `a` to `b` and `b` to `a` buffers sizes.
 #[cfg_attr(docsrs, doc(cfg(feature = "io-util")))]
-pub async fn copy_bidirectional_with_size<A, B>(a: &mut A, b: &mut B, a_to_b_buf_size: usize, b_to_a_buf_size: usize) -> Result<(u64, u64), std::io::Error>
- where
- A: AsyncRead + AsyncWrite + Unpin + ?Sized,
- B: AsyncRead + AsyncWrite + Unpin + ?Sized,
+pub async fn copy_bidirectional_with_size<A, B>(
+ a: &mut A,
+ b: &mut B,
+ a_to_b_buf_size: usize,
+ b_to_a_buf_size: usize,
+) -> Result<(u64, u64), std::io::Error>
+where
+ A: AsyncRead + AsyncWrite + Unpin + ?Sized,
+ B: AsyncRead + AsyncWrite + Unpin + ?Sized,
 {
- copy_bidirectional_impl(a, b, CopyBuffer::new(a_to_b_buf_size), CopyBuffer::new(b_to_a_buf_size)).await
+ copy_bidirectional_impl(
+ a,
+ b,
+ CopyBuffer::new(a_to_b_buf_size),
+ CopyBuffer::new(b_to_a_buf_size),
+ )
+ .await
 }
 
-async fn copy_bidirectional_impl<A, B>(a: &mut A, b: &mut B, a_to_b_buffer: CopyBuffer, b_to_a_buffer: CopyBuffer) -> Result<(u64, u64), std::io::Error>
- where
- A: AsyncRead + AsyncWrite + Unpin + ?Sized,
- B: AsyncRead + AsyncWrite + Unpin + ?Sized,
+async fn copy_bidirectional_impl<A, B>(
+ a: &mut A,
+ b: &mut B,
+ a_to_b_buffer: CopyBuffer,
+ b_to_a_buffer: CopyBuffer,
+) -> Result<(u64, u64), std::io::Error>
+where
+ A: AsyncRead + AsyncWrite + Unpin + ?Sized,
+ B: AsyncRead + AsyncWrite + Unpin + ?Sized,
 {
  let mut a_to_b = TransferState::Running(a_to_b_buffer);
  let mut b_to_a = TransferState::Running(b_to_a_buffer);
@@ -108,5 +130,5 @@ async fn copy_bidirectional_impl<A, B>(a: &mut A, b: &mut B, a_to_b_buffer: Copy
 
  Poll::Ready(Ok((a_to_b, b_to_a)))
  })
-  .await
-}
+ .await
+}