summaryrefslogtreecommitdiff
path: root/src/event/sequence.rs
diff options
context:
space:
mode:
authorOwen Jacobson <owen@grimoire.ca>2024-10-30 02:01:31 -0400
committerOwen Jacobson <owen@grimoire.ca>2024-10-30 02:01:31 -0400
commit50a382528288248381b07c25719cbc9a519b4c81 (patch)
tree01fc7a2997c3678aa687a75e2e7d56ef0876b450 /src/event/sequence.rs
parent70591c5ac10069a4ae649bd6f79d769da9e32a98 (diff)
Resume points are no longer optional.
This is an inconsequential change for actual clients, since "resume from the beginning" was never a preferred mode of operation, and it simplifies some internals. It should also mean we get better query plans where `coalesce(cond, true)` was previously being used.
Diffstat (limited to 'src/event/sequence.rs')
-rw-r--r--src/event/sequence.rs9
1 files changed, 4 insertions, 5 deletions
diff --git a/src/event/sequence.rs b/src/event/sequence.rs
index 9bc399b..77281c2 100644
--- a/src/event/sequence.rs
+++ b/src/event/sequence.rs
@@ -1,6 +1,5 @@
use std::fmt;
-use super::ResumePoint;
use crate::clock::DateTime;
#[derive(Clone, Copy, Debug, Eq, PartialEq, serde::Serialize)]
@@ -51,18 +50,18 @@ impl fmt::Display for Sequence {
}
impl Sequence {
- pub fn up_to<E>(resume_point: ResumePoint) -> impl for<'e> Fn(&'e E) -> bool
+ pub fn up_to<E>(resume_point: Sequence) -> impl for<'e> Fn(&'e E) -> bool
where
E: Sequenced,
{
- move |event| resume_point.map_or(true, |resume_point| event.sequence() <= resume_point)
+ move |event| event.sequence() <= resume_point
}
- pub fn after<E>(resume_point: ResumePoint) -> impl for<'e> Fn(&'e E) -> bool
+ pub fn after<E>(resume_point: Sequence) -> impl for<'e> Fn(&'e E) -> bool
where
E: Sequenced,
{
- move |event| resume_point < Some(event.sequence())
+ move |event| resume_point < event.sequence()
}
pub fn start_from<E>(resume_point: Self) -> impl for<'e> Fn(&'e E) -> bool