async fn await_join_aggregates(
services: &Services,
sender_user: &UserId,
room_id: &RoomId,
state_events: &[PduEvent],
timeline_pdus: Vec<(PduCount, PduEvent)>,
joined_sender_member: Option<PduEvent>,
encrypted: bool,
initial: bool,
since: u64,
next_batch: u64,
last_privateread_update: u64,
send_notification_counts: bool,
filter: &FilterDefinition,
) -> JoinAggregates