diff --git a/crates/matrix-sdk/src/event_cache/redecryptor.rs b/crates/matrix-sdk/src/event_cache/redecryptor.rs index fc121760d..9debfa6de 100644 --- a/crates/matrix-sdk/src/event_cache/redecryptor.rs +++ b/crates/matrix-sdk/src/event_cache/redecryptor.rs @@ -146,6 +146,10 @@ use crate::{Room, room::PushContext}; type SessionId<'a> = &'a str; type OwnedSessionId = String; +type EventIdAndUtd = (OwnedEventId, Raw); +type EventIdAndEvent = (OwnedEventId, DecryptedRoomEvent); +type ResolvedUtd = (OwnedEventId, DecryptedRoomEvent, Option>); + /// The information sent across the channel to the long-running task requesting /// that the supplied set of sessions be retried. #[derive(Debug, Clone)] @@ -206,7 +210,7 @@ impl EventCache { &self, room_id: &RoomId, session_id: SessionId<'_>, - ) -> Result)>, EventCacheError> { + ) -> Result, EventCacheError> { let filter = |event: TimelineEvent| { let event_id = event.event_id(); @@ -231,7 +235,7 @@ impl EventCache { &self, room_id: &RoomId, session_id: SessionId<'_>, - ) -> Result, EventCacheError> { + ) -> Result, EventCacheError> { let filter = |event: TimelineEvent| { let event_id = event.event_id(); @@ -264,7 +268,7 @@ impl EventCache { async fn on_resolved_utds( &self, room_id: &RoomId, - events: Vec<(OwnedEventId, DecryptedRoomEvent, Option>)>, + events: Vec, ) -> Result<(), EventCacheError> { if events.is_empty() { trace!("No events were redecrypted or updated, nothing to replace");