async def on_new_receipts(self, min_stream_id: int, max_stream_id: int, affected_room_ids: Iterable[str]) -> None:
    if (not self.pushers):
        return
    try:
        users_affected = (await self.store.get_users_sent_receipts_between((min_stream_id - 1), max_stream_id))
        for u in users_affected:
            expired = (await self._account_validity_handler.is_user_expired(u))
            if expired:
                continue
            if (u in self.pushers):
                for p in self.pushers[u].values():
                    p.on_new_receipts(min_stream_id, max_stream_id)
    except Exception:
        logger.exception('Exception in pusher on_new_receipts')
async def on_new_receipts(self, min_stream_id: int, max_stream_id: int, affected_room_ids: Iterable[str]) -> None:
    if (not self.pushers):
        return
    try:
        users_affected = (await self.store.get_users_sent_receipts_between((min_stream_id - 1), max_stream_id))
        for u in users_affected:
            expired = (await self._account_validity_handler.is_user_expired(u))
            if expired:
                continue
            if (u in self.pushers):
                for p in self.pushers[u].values():
                    p.on_new_receipts(min_stream_id, max_stream_id)
    except Exception:
        logger.exception('Exception in pusher on_new_receipts')