fix: check for NotFound error at the correct site in OperatorExt::async_reader_if_exists

src/operator_ext.rs

@@ -15,8 +15,9 @@ impl Operator {
         &self,
         path: &str,
     ) -> Result<Option<FuturesAsyncReader>, Error> {
-        match self.reader(path).await {
+        let reader = self.reader(path).await?;
-            Ok(reader) => Ok(Some(reader.into_futures_async_read(..).await?)),
+        match reader.into_futures_async_read(..).await {
+            Ok(reader) => Ok(Some(reader)),
             Err(error) if matches!(error.kind(), ErrorKind::NotFound) => Ok(None),
             Err(error) => Err(error),
         }