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

chore(tests): make new threads discovery deterministic

Browse Source
This commit is contained in:
Benjamin Bouvier
2025-07-08 10:05:59 +02:00
parent 96fbbd3cd8
commit db477a84bf
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
crates/matrix-sdk/src/event_cache/room/mod.rs
View File

@@ -603,7 +603,7 @@ pub(super) enum LoadMoreEventsBackwardsOutcome {
// Use a private module to hide `events` to this parent module.
mod private {
use std::{
collections::{HashMap, HashSet},
collections::{BTreeMap, HashMap, HashSet},
sync::{atomic::AtomicUsize, Arc},
};
@@ -1428,7 +1428,7 @@ mod private {
// Update the store before doing the post-processing.
self.propagate_changes().await?;
let mut new_events_by_thread: HashMap<_, Vec<_>> = HashMap::new();
let mut new_events_by_thread: BTreeMap<_, Vec<_>> = BTreeMap::new();
for event in events {
self.maybe_apply_new_redaction(&event).await?;
@@ -1464,7 +1464,7 @@ mod private {
#[instrument(skip_all)]
async fn update_threads(
&mut self,
new_events_by_thread: HashMap<OwnedEventId, Vec<Event>>,
new_events_by_thread: BTreeMap<OwnedEventId, Vec<Event>>,
is_sync: bool,
) -> Result<(), EventCacheError> {
for (thread_root, new_events) in new_events_by_thread {