async fn collect_required_state(
services: &Services,
sender_user: &UserId,
room_id: &RoomId,
required_state: &[(StateEventType, StateKey)],
timeline_pdus: &[(PduCount, PduEvent)],
encrypted: bool,
) -> Vec<Raw<AnySyncStateEvent>>