drop nonfuture
parent
72eb29d766
commit
97caaebc09
|
|
@ -153,19 +153,6 @@ impl File {
|
|||
Events::new(&self.file)
|
||||
}
|
||||
|
||||
fn events_non_future(&self) -> Result<Events, String> {
|
||||
let events = self.events()?;
|
||||
let now = Delta::now_time();
|
||||
Ok(Events(
|
||||
events
|
||||
.0
|
||||
.iter()
|
||||
.filter(|x| x.ts <= now)
|
||||
.map(|x| x.clone())
|
||||
.collect(),
|
||||
))
|
||||
}
|
||||
|
||||
pub fn persist_unpersisted_stage(&self) -> Result<(), String> {
|
||||
let events = self.events()?;
|
||||
let stage_mod_time = std::fs::metadata(&self.file)
|
||||
|
|
@ -197,7 +184,7 @@ impl File {
|
|||
}
|
||||
|
||||
pub fn stage_persisted(&self) -> Result<(), String> {
|
||||
let persisted_as_snapshot = self.events_non_future()?.snapshot()?;
|
||||
let persisted_as_snapshot = self.events()?.snapshot()?;
|
||||
let plaintext = serde_yaml::to_string(&persisted_as_snapshot).unwrap();
|
||||
let mut f = std::fs::File::create(&self.file).expect("failed to open file for writing");
|
||||
writeln!(f, "{}", plaintext).expect("failed to write");
|
||||
|
|
@ -207,7 +194,7 @@ impl File {
|
|||
pub fn persist_stage(&self) -> Result<(), String> {
|
||||
self.persist_unpersisted_stage()?;
|
||||
|
||||
let persisted = self.events_non_future()?.snapshot()?;
|
||||
let persisted = self.events()?.snapshot()?;
|
||||
|
||||
let stage = self.stage()?;
|
||||
|
||||
|
|
|
|||
Loading…
Reference in New Issue