This is an automated email from the ASF dual-hosted git repository. xuanwo pushed a commit to branch polish-lister in repository https://gitbox.apache.org/repos/asf/incubator-opendal.git
commit ed3d112c6a3274ce4f905dab4fcbdd0a09df2a90 Author: Xuanwo <[email protected]> AuthorDate: Wed Nov 15 23:12:37 2023 +0800 Fix test Signed-off-by: Xuanwo <[email protected]> --- core/src/layers/retry.rs | 15 ++++++++++++--- 1 file changed, 12 insertions(+), 3 deletions(-) diff --git a/core/src/layers/retry.rs b/core/src/layers/retry.rs index bed437900..3db6f793b 100644 --- a/core/src/layers/retry.rs +++ b/core/src/layers/retry.rs @@ -1314,6 +1314,7 @@ mod tests { struct MockLister { attempt: usize, } + #[async_trait] impl oio::List for MockLister { fn poll_next(&mut self, _: &mut Context<'_>) -> Poll<Result<Option<oio::Entry>>> { @@ -1328,15 +1329,23 @@ mod tests { "hello", Metadata::new(EntryMode::FILE), ))), - 3 => Err( + 3 => Ok(Some(oio::Entry::new( + "world", + Metadata::new(EntryMode::FILE), + ))), + 4 => Err( Error::new(ErrorKind::Unexpected, "retryable internal server error") .set_temporary(), ), - 4 => Ok(Some(oio::Entry::new( + 5 => Ok(Some(oio::Entry::new( "2023/", Metadata::new(EntryMode::DIR), ))), - 5 => Ok(None), + 6 => Ok(Some(oio::Entry::new( + "0208/", + Metadata::new(EntryMode::DIR), + ))), + 7 => Ok(None), _ => { unreachable!() }
