This is an automated email from the ASF dual-hosted git repository. xuanwo pushed a commit to branch fix-remove in repository https://gitbox.apache.org/repos/asf/incubator-opendal.git
commit b2dd4375e2880ec5dbeccb7fc0781bff4924481a Author: Xuanwo <[email protected]> AuthorDate: Mon Nov 27 21:14:52 2023 +0800 fix(core): Path in remove not normalized Signed-off-by: Xuanwo <[email protected]> --- core/src/types/operator/operator.rs | 2 ++ 1 file changed, 2 insertions(+) diff --git a/core/src/types/operator/operator.rs b/core/src/types/operator/operator.rs index c0f08d515..635577976 100644 --- a/core/src/types/operator/operator.rs +++ b/core/src/types/operator/operator.rs @@ -911,6 +911,8 @@ impl Operator { /// # } /// ``` pub async fn remove_via(&self, input: impl Stream<Item = String> + Unpin) -> Result<()> { + let input = input.map(|v| normalize_path(&v)); + if self.info().full_capability().batch { let mut input = input .map(|v| (v, OpDelete::default().into()))
