diff options
| author | Owen Jacobson <owen@grimoire.ca> | 2024-10-01 22:30:04 -0400 |
|---|---|---|
| committer | Owen Jacobson <owen@grimoire.ca> | 2024-10-01 22:43:14 -0400 |
| commit | b8392a5fe824eff46f912a58885546e7b0f37e6f (patch) | |
| tree | ff4061bbf4be30c53f84c179f86e8e6ab584dbda /src/test | |
| parent | 7645411bcf7201e3a4927566da78080dc6a84ccf (diff) | |
Track event sequences globally, not per channel.
Per-channel event sequences were a cute idea, but it made reasoning about event resumption much, much harder (case in point: recovering the order of events in a partially-ordered collection is quadratic, since it's basically graph sort). The minor overhead of a global sequence number is likely tolerable, and this simplifies both the API and the internals.
Diffstat (limited to 'src/test')
| -rw-r--r-- | src/test/fixtures/filter.rs | 12 |
1 files changed, 4 insertions, 8 deletions
diff --git a/src/test/fixtures/filter.rs b/src/test/fixtures/filter.rs index fbebced..c31fa58 100644 --- a/src/test/fixtures/filter.rs +++ b/src/test/fixtures/filter.rs @@ -2,14 +2,10 @@ use futures::future; use crate::events::types; -pub fn messages() -> impl FnMut(&types::ResumableEvent) -> future::Ready<bool> { - |types::ResumableEvent(_, event)| { - future::ready(matches!(event.data, types::ChannelEventData::Message(_))) - } +pub fn messages() -> impl FnMut(&types::ChannelEvent) -> future::Ready<bool> { + |event| future::ready(matches!(event.data, types::ChannelEventData::Message(_))) } -pub fn created() -> impl FnMut(&types::ResumableEvent) -> future::Ready<bool> { - |types::ResumableEvent(_, event)| { - future::ready(matches!(event.data, types::ChannelEventData::Created(_))) - } +pub fn created() -> impl FnMut(&types::ChannelEvent) -> future::Ready<bool> { + |event| future::ready(matches!(event.data, types::ChannelEventData::Created(_))) } |
