def on_new_notifications(self, max_token: RoomStreamToken) -> None:
    if (not self.pushers):
        return
    max_stream_id = max_token.stream
    if (max_stream_id < self._last_room_stream_id_seen):
        return
    self._on_new_notifications(max_token)
def on_new_notifications(self, max_token: RoomStreamToken) -> None:
    if (not self.pushers):
        return
    max_stream_id = max_token.stream
    if (max_stream_id < self._last_room_stream_id_seen):
        return
    self._on_new_notifications(max_token)