Merge pull request #22 from psarna/storfixup

fixup: implement Stream for JsonOnDiskStream under a feature
This commit is contained in:
Pekka Enberg
2023-04-20 16:03:51 +03:00
committed by GitHub

View File

@@ -44,6 +44,7 @@ pub struct JsonOnDiskStream {
inner: tokio_stream::wrappers::LinesStream<tokio::io::BufReader<tokio::fs::File>>,
}
#[cfg(feature = "tokio")]
impl futures::stream::Stream for JsonOnDiskStream {
type Item = Mutation;