diff --git a/src/service/rooms/event_handler/fetch_and_handle_outliers.rs b/src/service/rooms/event_handler/fetch_and_handle_outliers.rs index a2855c750..527cdb61c 100644 --- a/src/service/rooms/event_handler/fetch_and_handle_outliers.rs +++ b/src/service/rooms/event_handler/fetch_and_handle_outliers.rs @@ -384,9 +384,8 @@ impl super::Service { .send_federation_request(&remote, get_event::v1::Request::new(event_id.clone())) .await?; - let (calculated_event_id, value) = self - .parse_incoming_pdu_with_known_room(&res.pdu, room_version_rules) - .await?; + let (calculated_event_id, value) = + self.parse_incoming_pdu_with_known_room(&res.pdu, room_version_rules)?; if calculated_event_id != event_id { Err!(Request(BadJson(warn!( diff --git a/src/service/rooms/event_handler/parse_incoming_pdu.rs b/src/service/rooms/event_handler/parse_incoming_pdu.rs index 067851515..e30fdebb0 100644 --- a/src/service/rooms/event_handler/parse_incoming_pdu.rs +++ b/src/service/rooms/event_handler/parse_incoming_pdu.rs @@ -105,7 +105,7 @@ impl super::Service { Ok(()) } - pub async fn parse_incoming_pdu_with_known_room( + pub(super) fn parse_incoming_pdu_with_known_room( &self, pdu: &RawJsonValue, room_version_rules: &RoomVersionRules,