chore: rename AsyncFile::to_file to AsyncFile::boxed

tonbo-io · Jul 17, 2024 · 69b5cd2 · 69b5cd2
1 parent 7bf3313
commit 69b5cd2
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/src/fs/mod.rs b/src/fs/mod.rs
@@ -20,7 +20,7 @@ pub enum FileType {
 }
 
 pub trait AsyncFile: AsyncRead + AsyncWrite + AsyncSeek + Send + Sync + Unpin + 'static {
-    fn to_file(self) -> Box<dyn AsyncFile>
+    fn boxed(self) -> Box<dyn AsyncFile>
     where
         Self: Sized,
     {

diff --git a/src/ondisk/sstable.rs b/src/ondisk/sstable.rs
@@ -126,7 +126,7 @@ mod tests {
         let file = TokioExecutor::open(&temp_dir.path().join("test.parquet"))
             .await
             .unwrap()
-            .to_file();
+            .boxed();
         let mut sstable = SsTable::<Test>::open(file);
 
         sstable.write(record_batch).await.unwrap();

diff --git a/src/version/mod.rs b/src/version/mod.rs
@@ -99,7 +99,7 @@ where
         let file = E::open(self.option.table_path(gen))
             .await
             .map_err(VersionError::Io)?
-            .to_file();
+            .boxed();
         let table = SsTable::open(file);
         table.get(key).await.map_err(VersionError::Parquet)
     }
@@ -124,7 +124,7 @@ where
             let file = E::open(self.option.table_path(&scope.gen))
                 .await
                 .map_err(VersionError::Io)?
-                .to_file();
+                .boxed();
             let table = SsTable::open(file);
 
             iters.push(ScanStream::SsTable {