RhodeCode

    void first(Item& item) const {

      container->first(item);

    }

    /// \brief Next item in the container.

    ///

    /// Returns the next item in the container. It is

    /// for iterate on the container.

    void next(Item& item) const {

      container->next(item);

    }

    /// \brief Returns the id of the item.

    ///

    /// Returns the id of the item provided by the container.

    int id(const Item& item) const {

      return container->id(item);

    }

    /// \brief Returns the maximum id of the container.

    ///

    /// Returns the maximum id of the container.

    int maxId() const {

      return container->maxId(Item());

    }

  protected:

    void attach(ObserverBase& observer) {

      observer._index = _observers.insert(_observers.begin(), &observer);

      observer._notifier = this;

    }

    void detach(ObserverBase& observer) {

      _observers.erase(observer._index);

      observer._index = _observers.end();

      observer._notifier = 0;

    }

  public:

    /// \brief Notifies all the registed observers about an item added to

    /// the container.

    ///

    /// It notifies all the registed observers about an item added to

    /// the container.

    ///

    void add(const Item& item) {

      typename Observers::reverse_iterator it;

      try {

        for (it = _observers.rbegin(); it != _observers.rend(); ++it) {

          (*it)->add(item);

        }

      } catch (...) {

        typename Observers::iterator jt;

        for (jt = it.base(); jt != _observers.end(); ++jt) {

          (*jt)->erase(item);

        }

        throw;

      }

    }

    /// \brief Notifies all the registed observers about more item added to

    /// the container.

    ///

    /// It notifies all the registed observers about more item added to

    /// the container.

    ///

    void add(const std::vector<Item>& items) {

      typename Observers::reverse_iterator it;

      try {

        for (it = _observers.rbegin(); it != _observers.rend(); ++it) {

          (*it)->add(items);

        }

      } catch (...) {

        typename Observers::iterator jt;

        for (jt = it.base(); jt != _observers.end(); ++jt) {

          (*jt)->erase(items);

        }

        throw;

      }

    }

    /// \brief Notifies all the registed observers about an item erased from

    /// the container.

    ///

    /// It notifies all the registed observers about an item erased from

    /// the container.

    ///

    void erase(const Item& item) throw() {

      typename Observers::iterator it = _observers.begin();

      while (it != _observers.end()) {

        try {

          (*it)->erase(item);

          ++it;

        } catch (const ImmediateDetach&) {

          (*it)->_index = _observers.end();

          (*it)->_notifier = 0;

        }

      }

    }

    /// \brief Notifies all the registed observers about more item erased

    /// from the container.

    ///

    /// It notifies all the registed observers about more item erased from

    /// the container.

    ///

    void erase(const std::vector<Item>& items) {

      typename Observers::iterator it = _observers.begin();

      while (it != _observers.end()) {

        try {

          (*it)->erase(items);

          ++it;

        } catch (const ImmediateDetach&) {

          (*it)->_index = _observers.end();

          (*it)->_notifier = 0;

        }

      }

    }

    /// \brief Notifies all the registed observers about the container is

    /// built.

    ///

    /// Notifies all the registed observers about the container is built

    /// from an empty container.

    void build() {

      typename Observers::reverse_iterator it;

      try {

        for (it = _observers.rbegin(); it != _observers.rend(); ++it) {

          (*it)->build();

        }

      } catch (...) {

        typename Observers::iterator jt;

        for (jt = it.base(); jt != _observers.end(); ++jt) {

          (*jt)->clear();

        }

        throw;

      }

    }

    /// \brief Notifies all the registed observers about all items are

    /// erased.

    ///

    /// Notifies all the registed observers about all items are erased

    /// from the container.

    void clear() {

      typename Observers::iterator it = _observers.begin();

      while (it != _observers.end()) {

        try {

          (*it)->clear();

          ++it;

        } catch (const ImmediateDetach&) {

          (*it)->_index = _observers.end();

          (*it)->_notifier = 0;

        }

      }

    }

  };

}

#endif