From 4833403d654da909924b3d6515a26fcfec1fe8e1 Mon Sep 17 00:00:00 2001 From: Benjamin Bouvier Date: Wed, 26 Feb 2025 12:05:01 +0100 Subject: [PATCH] refactor(event cache): simplify signature of `RoomEventCacheState::with_events_mut` --- crates/matrix-sdk/src/event_cache/pagination.rs | 2 +- crates/matrix-sdk/src/event_cache/room/mod.rs | 12 ++++++------ 2 files changed, 7 insertions(+), 7 deletions(-) diff --git a/crates/matrix-sdk/src/event_cache/pagination.rs b/crates/matrix-sdk/src/event_cache/pagination.rs index b196e2d36..000f78728 100644 --- a/crates/matrix-sdk/src/event_cache/pagination.rs +++ b/crates/matrix-sdk/src/event_cache/pagination.rs @@ -306,7 +306,7 @@ impl RoomPagination { events.clear(); } - let ((), sync_timeline_events_diffs) = state + let sync_timeline_events_diffs = state .with_events_mut(|room_events| { // Reverse the order of the events as `/messages` has been called with `dir=b` // (backwards). The `RoomEvents` API expects the first event to be the oldest. diff --git a/crates/matrix-sdk/src/event_cache/room/mod.rs b/crates/matrix-sdk/src/event_cache/room/mod.rs index bcd7bf5b7..f727db632 100644 --- a/crates/matrix-sdk/src/event_cache/room/mod.rs +++ b/crates/matrix-sdk/src/event_cache/room/mod.rs @@ -547,7 +547,7 @@ impl RoomEventCacheInner { // Add the previous back-pagination token (if present), followed by the timeline // events themselves. - let ((), sync_timeline_events_diffs_next) = state + let sync_timeline_events_diffs_next = state .with_events_mut(|room_events| { // If we only received duplicated events, we don't need to store the gap: if // there was a gap, we'd have received an unknown event at the tail of @@ -1052,7 +1052,7 @@ mod private { } // In-memory events. - let ((), timeline_event_diffs) = self + let timeline_event_diffs = self .with_events_mut(|room_events| { // `remove_events_by_position` sorts the positions by itself. room_events @@ -1186,14 +1186,14 @@ mod private { /// linked chunk, as vector diff, so the caller may propagate /// such updates, if needs be. #[must_use = "Updates as `VectorDiff` must probably be propagated via `RoomEventCacheUpdate`"] - pub async fn with_events_mut O>( + pub async fn with_events_mut( &mut self, func: F, - ) -> Result<(O, Vec>), EventCacheError> { - let output = func(&mut self.events); + ) -> Result>, EventCacheError> { + func(&mut self.events); self.propagate_changes().await?; let updates_as_vector_diffs = self.events.updates_as_vector_diffs(); - Ok((output, updates_as_vector_diffs)) + Ok(updates_as_vector_diffs) } } }