mirror/matrix-rust-sdk
1
0
Fork 0
mirror of https://github.com/matrix-org/matrix-rust-sdk.git synced 2026-05-09 00:15:23 -04:00
Code Issues Packages Projects Releases Wiki Activity

timeline: inline TimelineInnerStateTransaction::handle_live_event

Browse Source
This commit is contained in:
Benjamin Bouvier
2024-03-14 15:53:48 +01:00
parent 52a5a86cf9
commit 117307eaff
1 changed files with 14 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

35
crates/matrix-sdk-ui/src/timeline/inner/state.rs
View File

@@ -184,7 +184,13 @@ impl TimelineInnerState {
settings: &TimelineInnerSettings,
) {
let mut txn = self.transaction();
txn.handle_live_event(event, room_data_provider, settings).await;
txn.handle_remote_event(
event,
TimelineItemPosition::End { from_cache: false },
room_data_provider,
settings,
)
.await;
txn.commit();
}
@@ -464,29 +470,16 @@ impl TimelineInnerStateTransaction<'_> {
let num_events = timeline.events.len();
for (i, event) in timeline.events.into_iter().enumerate() {
trace!("Handling event {} out of {num_events}", i + 1);
self.handle_live_event(event, room_data_provider, settings).await;
self.handle_remote_event(
event,
TimelineItemPosition::End { from_cache: false },
room_data_provider,
settings,
)
.await;
}
}
/// Handle a live remote event.
///
/// Shorthand for `handle_remote_event` with a `position` of
/// `TimelineItemPosition::End { from_cache: false }`.
async fn handle_live_event<P: RoomDataProvider>(
&mut self,
event: SyncTimelineEvent,
room_data_provider: &P,
settings: &TimelineInnerSettings,
) -> (Option<OwnedEventId>, HandleEventResult) {
self.handle_remote_event(
event,
TimelineItemPosition::End { from_cache: false },
room_data_provider,
settings,
)
.await
}
/// Handle a remote event.
///
/// Returns the number of timeline updates that were made.