replace PhantomData in async_db::Writer
for Send for Writer
This commit is contained in:
parent
b768d27f83
commit
a1a1d41403
@ -1,4 +1,4 @@
|
|||||||
use std::{marker::PhantomData, path::Path, sync::Arc};
|
use std::{path::Path, sync::Arc};
|
||||||
|
|
||||||
use async_compression::tokio::bufread::ZstdDecoder;
|
use async_compression::tokio::bufread::ZstdDecoder;
|
||||||
use async_compression::tokio::write::ZstdEncoder;
|
use async_compression::tokio::write::ZstdEncoder;
|
||||||
@ -48,7 +48,7 @@ where
|
|||||||
data_buf: Vec<u8>,
|
data_buf: Vec<u8>,
|
||||||
table: Vec<LSize>,
|
table: Vec<LSize>,
|
||||||
compress_lvl: Level,
|
compress_lvl: Level,
|
||||||
_t: PhantomData<*const T>,
|
_t: Option<Arc<T>>, // PhantomData replacement
|
||||||
}
|
}
|
||||||
|
|
||||||
impl<T> Writer<T>
|
impl<T> Writer<T>
|
||||||
@ -69,7 +69,7 @@ where
|
|||||||
data_buf,
|
data_buf,
|
||||||
table,
|
table,
|
||||||
compress_lvl,
|
compress_lvl,
|
||||||
_t: PhantomData,
|
_t: None,
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user