fn collect_room_events<'a>(
services: &'a Services,
sender_user: &'a UserId,
timeline_pdus: Vec<(PduCount, PduEvent)>,
joined_sender_member: Option<PduEvent>,
encrypted: bool,
filter: &'a FilterDefinition,
) -> impl Future<Output = Vec<PduEvent>> + Send + 'a