This is an automated email from the ASF dual-hosted git repository. xuanwo pushed a commit to branch polish-details in repository https://gitbox.apache.org/repos/asf/incubator-opendal.git
commit eba2478139b3de19634162dc8c6e6a3d948d23b9 Author: Xuanwo <[email protected]> AuthorDate: Thu Sep 14 15:41:36 2023 +0800 save work Signed-off-by: Xuanwo <[email protected]> --- core/src/layers/concurrent_limit.rs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/core/src/layers/concurrent_limit.rs b/core/src/layers/concurrent_limit.rs index b09408d45..c20ef4108 100644 --- a/core/src/layers/concurrent_limit.rs +++ b/core/src/layers/concurrent_limit.rs @@ -289,13 +289,13 @@ impl<R: oio::Write> oio::Write for ConcurrentLimitWrapper<R> { self.inner.poll_write(cx, bs) } - fn poll_abort(&mut self, cx: &mut Context<'_>) -> Poll<Result<()>> { - self.inner.poll_abort(cx) - } - fn poll_close(&mut self, cx: &mut Context<'_>) -> Poll<Result<()>> { self.inner.poll_close(cx) } + + fn poll_abort(&mut self, cx: &mut Context<'_>) -> Poll<Result<()>> { + self.inner.poll_abort(cx) + } } impl<R: oio::BlockingWrite> oio::BlockingWrite for ConcurrentLimitWrapper<R> {
