Skip to content

Commit

Permalink
Try to fix flaky test
Browse files Browse the repository at this point in the history
  • Loading branch information
jmartinesp committed Dec 10, 2024
1 parent 2372394 commit fe0de31
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
4 changes: 2 additions & 2 deletions crates/matrix-sdk/src/room/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -3219,9 +3219,9 @@ impl Room {
let (current_seen_ids, mut seen_request_ids_stream) =
this.subscribe_to_seen_join_request_ids().await?;

let combined_stream = stream! {
let mut room_info_stream = this.subscribe_info();
let mut room_info_stream = this.subscribe_info();

let combined_stream = stream! {
// Emit current requests to join
match this.clone().get_current_join_requests(&current_seen_ids).await {
Ok(initial_requests) => yield initial_requests,
Expand Down
4 changes: 2 additions & 2 deletions crates/matrix-sdk/tests/integration/room/joined.rs
Original file line number Diff line number Diff line change
Expand Up @@ -935,13 +935,13 @@ async fn test_subscribe_to_requests_to_join_reloads_members_on_limited_sync() {
pin_mut!(stream);

// We receive an initial request to join from Alice
let initial = assert_next_with_timeout!(stream, 100);
let initial = assert_next_with_timeout!(stream, 500);
assert!(!initial.is_empty());

// This limited sync should trigger a new emission of join requests, with a
// reloading of the room members
server.sync_room(&client, JoinedRoomBuilder::new(room_id).set_timeline_limited()).await;

// We should receive a new list of join requests
assert_next_with_timeout!(stream, 100);
assert_next_with_timeout!(stream, 500);
}

0 comments on commit fe0de31

Please sign in to comment.