This is an automated email from the ASF dual-hosted git repository. xuanwo pushed a commit to branch refactor-write in repository https://gitbox.apache.org/repos/asf/incubator-opendal.git
commit a461f479f60dd6fec979542ef3001df961a9d9c3 Author: Xuanwo <[email protected]> AuthorDate: Thu Sep 7 23:31:52 2023 +0800 Make clippy happy Signed-off-by: Xuanwo <[email protected]> --- core/src/layers/retry.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/core/src/layers/retry.rs b/core/src/layers/retry.rs index 04495df8d..f41586dfa 100644 --- a/core/src/layers/retry.rs +++ b/core/src/layers/retry.rs @@ -876,7 +876,7 @@ impl<R: oio::Write, I: RetryInterceptor> oio::Write for RetryWrapper<R, I> { let mut backoff = self.builder.build(); loop { - match self.inner.write(bs.clone()).await { + match self.inner.write(bs).await { Ok(v) => return Ok(v), Err(e) if !e.is_temporary() => return Err(e), Err(e) => match backoff.next() { @@ -953,7 +953,7 @@ impl<R: oio::Write, I: RetryInterceptor> oio::Write for RetryWrapper<R, I> { impl<R: oio::BlockingWrite, I: RetryInterceptor> oio::BlockingWrite for RetryWrapper<R, I> { fn write(&mut self, bs: &dyn Buf) -> Result<usize> { - { || self.inner.write(bs.clone()) } + { || self.inner.write(bs) } .retry(&self.builder) .when(|e| e.is_temporary()) .notify(|err, dur| {
