diff --git a/integrations/dav-server/src/dir.rs b/integrations/dav-server/src/dir.rs index d7a5aa6af7fe..4fbe36857806 100644 --- a/integrations/dav-server/src/dir.rs +++ b/integrations/dav-server/src/dir.rs @@ -15,29 +15,33 @@ // specific language governing permissions and limitations // under the License. +use super::metadata::OpendalMetaData; +use super::utils::*; use dav_server::fs::{DavDirEntry, DavMetaData, FsResult}; use futures::StreamExt; use futures::{FutureExt, Stream}; +use opendal::raw::normalize_path; use opendal::Operator; use opendal::{Entry, Lister}; use std::pin::Pin; use std::task::Poll::Ready; use std::task::{ready, Context, Poll}; -use opendal::raw::normalize_path; -use super::metadata::OpendalMetaData; -use super::utils::*; /// OpendalStream is a stream of `DavDirEntry` that is used to list the contents of a directory. pub struct OpendalStream { op: Operator, lister: Lister, - path: String + path: String, } impl OpendalStream { /// Create a new opendal stream. pub fn new(op: Operator, lister: Lister, p: &str) -> Self { - OpendalStream { op, lister, path: normalize_path(p)} + OpendalStream { + op, + lister, + path: normalize_path(p), + } } } @@ -54,7 +58,7 @@ impl Stream for OpendalStream { continue; } let webdav_entry = OpendalDirEntry::new(dav_stream.op.clone(), entry); - return Ready(Some(Ok(Box::new(webdav_entry) as Box))) + return Ready(Some(Ok(Box::new(webdav_entry) as Box))); } None => return Ready(None), }