lib/src/async_db.rs

@@ -1,3 +1,4 @@
+use std::marker::PhantomData;
 use std::{path::Path, sync::Arc};
 
 use async_compression::tokio::bufread::ZstdDecoder;
@@ -48,7 +49,7 @@ where
     data_buf: Vec<u8>,
     table: Vec<LSize>,
     compress_lvl: Level,
-    _t: Option<Arc<T>>, // PhantomData replacement
+    _t: PhantomData<Arc<T>>,
 }
 
 impl<T> Writer<T>
@@ -69,7 +70,7 @@ where
             data_buf,
             table,
             compress_lvl,
-            _t: None,
+            _t: PhantomData,
         })
     }
 
@@ -132,7 +133,7 @@ where
     mmap: AsyncMmapFile,
     count: usize,
     first_pos: LSize,
-    _t: Option<Arc<T>>, // PhantomData replacement
+    _t: PhantomData<Arc<T>>,
 }
 
 impl<T> Reader<T>
@@ -157,7 +158,7 @@ where
             mmap,
             count,
             first_pos,
-            _t: None,
+            _t: PhantomData,
         })
     }